Trying to call a consumer method inside a SyncConsumer class
def alert_receive(self, event): # Get a message of the
alert.receive type off of channel_layers
content = json.dumps("Group send working")
self.send({
"type":"websocket.send", # then send a message
out on websocket protocol to whatever the 'self' channel is.
"text":content,
})
from a python script *outside of this consumer class* using the approach
from the docs:
from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)("AlertReceivers", {"type":
"alert.receive"})
The last line there raises this traceback:
Traceback (most recent call last):
File "/usr/lib/python3.5/code.py", line 91, in runcode
exec(code, self.locals)
File "<console>", line 1, in <module>
File "/usr/local/lib/python3.5/dist-packages/asgiref/sync.py", line 49,
in __call__
return call_result.result()
File "/usr/lib/python3.5/concurrent/futures/_base.py", line 398, in result
return self.__get_result()
File "/usr/lib/python3.5/concurrent/futures/_base.py", line 357, in
__get_result
raise self._exception
File "/usr/local/lib/python3.5/dist-packages/asgiref/sync.py", line 63,
in main_wrap
result = await self.awaitable(*args, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/channels_redis/core.py",
line 313, in group_send
pool = await self.connection(self.consistent_hash(group))
File "/usr/local/lib/python3.5/dist-packages/channels_redis/core.py",
line 377, in connection
self.pools[index] = await
aioredis.create_redis_pool(**self.hosts[index])
File
"/usr/local/lib/python3.5/dist-packages/aioredis/commands/__init__.py",
line 197, in create_redis_pool
loop=loop)
File "/usr/local/lib/python3.5/dist-packages/aioredis/pool.py", line 59,
in create_pool
await pool.wait_closed()
File "/usr/local/lib/python3.5/dist-packages/aioredis/pool.py", line 177,
in wait_closed
await asyncio.shield(self._close_waiter, loop=self._loop)
File "/usr/lib/python3.5/asyncio/futures.py", line 361, in __iter__
yield self # This tells Task to wait for completion.
RuntimeError: Task <Task pending coro=<AsyncToSync.main_wrap() running at
/usr/local/lib/python3.5/dist-packages/asgiref/sync.py:63>
cb=[_run_until_complete_cb() at
/usr/lib/python3.5/asyncio/base_events.py:164]> got Future <Future pending>
attached to a different loop
Note that if I do a
async_to_sync(self.channel_layer.group_send)("AlertReceivers", {"type":
"alert.receive"})
from *within *the consumer class, it works well and getting that
alert.receive type event onto the channel_layer and sending the JSON
encoded "Group send working" message out to all member channels of the
group, just like it should do from outside the consumer.
--
You received this message because you are subscribed to the Google Groups
"Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to django-users+unsubscr...@googlegroups.com.
To post to this group, send email to django-users@googlegroups.com.
Visit this group at https://groups.google.com/group/django-users.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/19d95ebf-99a3-4f9a-a020-47b8803a6cdb%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
