how did you test it ? did you use a specific cmd to excute ?
Le vendredi 16 février 2018 à 22:08:55 UTC+1, Luke Hebert a écrit :
> Trying to call the "alert_receive" consumer method
>
> import json
> from channels.consumer import SyncConsumer
> from channels.exceptions import StopConsumer
> from asgiref.sync import async_to_sync
> from channels.layers import get_channel_layer
>
> class ClientAlertPtrConsumer(SyncConsumer):
> def websocket_connect(self, event):
> async_to_sync(self.channel_layer.group_add)("AlertReceivers", self
> .channel_name)
> self.send({
> "type": "websocket.accept",
> })
>
> def websocket_receive(self, event):
> content = json.dumps("received")
> async_to_sync(self.channel_layer.group_send)("AlertReceivers", {
> "type":"alert.receive"})
>
> def websocket_disconnect(self, event):
> async_to_sync(self.channel_layer.group_discard)("AlertReceivers",
> self.channel_name)
> raise StopConsumer
>
> def alert_receive(self, event): # Get a message on
> the alert.receive type
> 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 *outside this consumer class *using the approach in documentation
> like this
>
> 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"})
>
>
> and getting the following traceback having to do with the
> concurrent.futures module:
>
> 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 the
> async_to_sync(channel_layer.group_send)("AlertReceivers", {'type':
> "alert.receive"})
>
> *within the websocket_receive method of the consumer class *works well*,
> *sending
> the event out onto redis-based channel layers and then sending json encoded
> "Group send working" WS message to client.
>
>
>
--
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 view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/e53418ed-daea-41fc-88e5-cdf5602d5859n%40googlegroups.com.
