aladagemre

import json
import redis
client = redis.StrictRedis(
    host='hostname',
    port=6379,
    db=0,
    password='password',
    ssl=True,
    ssl_cert_reqs=None
)

aladagemre

# Export data from source postgresql database.
pg_dump --format=custom --no-owner --verbose --file=backup.dump "$SOURCE_URL"

# Restore the data to the target postgresql database.
pg_restore --clean --if-exists --no-owner --verbose --dbname="$TARGET_URL" backup.dump

aladagemre

"""Consumer Sample for NATS
It creates a "durable pull consumer" named "TEST_DURABLE".
The consumer only listens to the "TEST.pushed" subject.
It prints the json messages pushed to the "TEST.pushed" subject."""
import asyncio
import json
from nats.aio.client import Client as NATS

async def main():
    nc = NATS()