How can I publish a message in Redis channel asynchronously with python?

Question

In my existing djangorest api I want to publish a message in a Redis channel from side the python code. I want to do it asynchronously i.e, want to call an async function which will send a message to the channel and at the same time my api should response the user instead blocking at that redis communication.

Lets see example.

Below code is working well

#Python function (api function)
def create(self, request, *args, **kwargs):
    queryset = Order.objects.all()
    serializer_class = OrderSerializer
    #some business logic
    connection = redis.Redis(host=config("REDIS_SERVER_URL"), port=config("REDIS_SERVER_PORT"), db=config("REDIS_SERVER_DB"))
    connection.publish('my_channel', 'my pubsub message')
    
    return Response(      
        data={
            'status': True,
            'message': "Order Successfully Created",
            'data': response
        },
        status=status.HTTP_201_CREATED
    )

But I don't want to wait for redis connection and publishing the message rather want to do it asynchronously like below


async def publish_message(channel, message):
    connection = await redis.Redis(host=config("REDIS_SERVER_URL"), port=config("REDIS_SERVER_PORT"), db=config("REDIS_SERVER_DB"))
    await connection.publish('channel', 'my pubsub message')
    return "Nice"



#Python function (api function)
def create(self, request, *args, **kwargs):
    queryset = Order.objects.all()
    serializer_class = OrderSerializer
    #some business logic
    publish_message('my_channel', 'my pubsub message')
    
    return Response(      
        data={
            'status': True,
            'message': "Order Successfully Created",
            'data': response
        },
        status=status.HTTP_201_CREATED
    )

V-outsider · Accepted Answer · 2020-10-16 10:53:23Z

1

You can't await connection and redis, because they're not corutines. It will looks like:

 async def publish_message(channel, message):
        connection = redis.Redis(host=config("REDIS_SERVER_URL"), port=config("REDIS_SERVER_PORT"), db=config("REDIS_SERVER_DB"))
        connection.publish('channel', 'my pubsub message')
        return "Nice"

def it_works():
    await publish_message('gg', 'wp')

answered Oct 16, 2020 at 10:53

V-outsider

112 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How can I publish a message in Redis channel asynchronously with python?

1 Answer 1

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related