Yes, using rabbit...
CHANNEL_LAYERS = {
'default': {
'BACKEND': 'asgi_rabbitmq.RabbitmqChannelLayer',
'ROUTING': 'toogo.routing.channel_routing',
'CONFIG': {
'url': 'amqp://foo:bar@{0}:5672/%2F'.format(RABBITMQ_NODE),
},
},
}
This of course works fine (but we are clustering web servers):
CHANNEL_LAYERS = {
"default": {
"BACKEND": "asgiref.inmemory.ChannelLayer",
"ROUTING": "toogo.routing.channel_routing",
},
}
On Tuesday, December 12, 2017 at 1:33:55 PM UTC-5, Andrew Godwin wrote:
>
> Hm, that looks to be like logging from asgi_rabbitmq - could you post your
> settings configuration? And have you tried running with a different channel
> layer?
>
> Andrew
>
> On Tue, Dec 12, 2017 at 10:14 AM, Filbert <[email protected] <javascript:>>
> wrote:
>
>> Trying to come up with the proper command line to start Daphne in
>> production. It seems when I start, it heads off into a repeated processing
>> loop, my thought is that it should just be pending on a websocket
>> connection. Using asgi_rabbitmq.
>>
>> daphne -u /opt/daphne.sock --ws-protocol "graphql-ws" --proxy-headers -v
>> 2 asgi:channel_layer
>>
>> Seems to be repeated logging:
>>
>> Calling <bound method LayerChannel._on_synchronous_complete of <
>> LayerChannel number=2 OPEN conn=<LayerConnection OPEN socket=('127.0.0.1'
>> , 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq port=
>> 5672 virtual_host=/ ssl=False>>>> for "2:Queue.DeclareOk"
>> 0 blocked frames
>> Calling functools.partial(<bound method Protocol.queues_declared of <
>> asgi_rabbitmq.core.Protocol object at 0x7f1cd01f6a20>>, {
>> 'daphne.response.yLFVcixMCk!'}, set(), ['daphne.response.yLFVcixMCk!'],
>> False) for "2:Queue.DeclareOk"
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback':
>> functools.partial(<bound method Protocol.no_message of <asgi_rabbitmq.
>> core.Protocol object at 0x7f1cd01f6a20>>, []), 'one_shot': True}
>> Processing 2:Basic.GetEmpty
>> Processing use of oneshot callback
>> 0 registered uses left
>>
>>
>> Any debugging ideas?
>>
>> Entering IOLoop
>> Connecting to 127.0.0.1:5672
>> Processing 0:Connection.Start
>> Processing use of oneshot callback
>> 0 registered uses left
>> Removing callback #0: {'arguments': None, 'only': None, 'calls': 0,
>> 'callback': <bound method LayerConnection._on_connection_start of
>> <LayerConnection PROTOCOL socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False>>>,
>> 'one_shot': True}
>> Calling <bound method LayerConnection._on_connection_start of <
>> LayerConnection PROTOCOL socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>> for "0:Connection.Start"
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerConnection._on_connection_tune of <LayerConnection START
>> socket=('127.0.0.1', 34690)->('127.0.0.1', 5672) params=<URLParameters
>> host=rabbitmq port=5672 virtual_host=/ ssl=False>>>, 'one_shot': True}
>> Processing 0:Connection.Tune
>> Processing use of oneshot callback
>> 0 registered uses left
>> Removing callback #0: {'arguments': None, 'only': None, 'calls': 0,
>> 'callback': <bound method LayerConnection._on_connection_tune of
>> <LayerConnection START socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False>>>,
>> 'one_shot': True}
>> Calling <bound method LayerConnection._on_connection_tune of <
>> LayerConnection START socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>> for "0:Connection.Tune"
>> Creating a HeartbeatChecker: 600
>> add_timeout: added timeout -1786684229378238513; deadline=600 at
>> 1513095706.3193622
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerConnection._on_connection_open of <LayerConnection TUNE
>> socket=('127.0.0.1', 34690)->('127.0.0.1', 5672) params=<URLParameters
>> host=rabbitmq port=5672 virtual_host=/ ssl=False>>>, 'one_shot': True}
>> Processing 0:Connection.OpenOk
>> Processing use of oneshot callback
>> 0 registered uses left
>> Removing callback #0: {'arguments': None, 'only': None, 'calls': 0,
>> 'callback': <bound method LayerConnection._on_connection_open of
>> <LayerConnection TUNE socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False>>>,
>> 'one_shot': True}
>> Calling <bound method LayerConnection._on_connection_open of <
>> LayerConnection TUNE socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>> for "0:Connection.OpenOk"
>> Processing 0:_on_connection_open
>> Calling <bound method RabbitmqConnection.start_loop of
>> <asgi_rabbitmq.core.RabbitmqConnection object at 0x7f1cbcf349b0>> for
>> "0:_on_connection_open"
>> Added: {'arguments': None, 'only': <LayerChannel number=1 CLOSED
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>, 'calls': 1, 'callback': <bound method
>> >>>LayerConnection._on_channel_cleanup
>> of <LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>, 'one_shot': True}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_getempty of <LayerChannel number=1 OPENING
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_cancel of <LayerChannel number=1 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_flow of <LayerChannel number=1 OPENING
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_close of <LayerChannel number=1 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': True}
>> Entering blocking state on frame <Channel.Open(['out_of_band='])>;
>> acceptable_replies=[<class 'pika.spec.Channel.OpenOk'>]
>> Adding on_synchronous_complete callback
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_synchronous_complete of <LayerChannel number=1
>> OPENING conn=<LayerConnection OPEN socket=('127.0.0.1',
>> 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq port=5672
>> virtual_host=/ ssl=False>>>>, 'one_shot': True}
>> Adding passed-in callback
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_openok of <LayerChannel number=1 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': True}
>> Added: {'arguments': None, 'only': <LayerChannel number=2 CLOSED
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>, 'calls': 1, 'callback': <bound method
>> >>>LayerConnection._on_channel_cleanup
>> of <LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>, 'one_shot': True}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_getempty of <LayerChannel number=2 OPENING
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_cancel of <LayerChannel number=2 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'callback': <bound method
>> LayerChannel._on_flow of <LayerChannel number=2 OPENING
>> conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=False
>> >>>>, 'one_shot': False}
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_close of <LayerChannel number=2 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': True}
>> Entering blocking state on frame <Channel.Open(['out_of_band='])>;
>> acceptable_replies=[<class 'pika.spec.Channel.OpenOk'>]
>> Adding on_synchronous_complete callback
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_synchronous_complete of <LayerChannel number=2
>> OPENING conn=<LayerConnection OPEN socket=('127.0.0.1',
>> 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq port=5672
>> virtual_host=/ ssl=False>>>>, 'one_shot': True}
>> Adding passed-in callback
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_openok of <LayerChannel number=2 OPENING conn=<
>> LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1', 5672)
>> params=<URLParameters host=rabbitmq port=5672 virtual_host=/
>> ssl=False>>>>, 'one_shot': True}
>> Processing 1:Channel.OpenOk
>> Processing use of oneshot callback
>> 0 registered uses left
>> Removing callback #0: {'arguments': None, 'only': None, 'calls': 0,
>> 'callback': <bound method LayerChannel._on_synchronous_complete of
>> <LayerChannel number=1 OPENING conn=<LayerConnection OPEN
>> socket=('127.0.0.1', 34690)->('127.0.0.1', 5672) params=<URLParameters
>> host=rabbitmq port=5672 virtual_host=/ ssl=False>>>>, 'one_shot': True}
>> Processing use of oneshot callback
>> 0 registered uses left
>> Removing callback #0: {'arguments': None, 'only': None, 'calls': 0,
>> 'callback': <bound method LayerChannel._on_openok of <LayerChannel number=1
>> OPENING conn=<LayerConnection OPEN socket=('127.0.0.1',
>> 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq port=5672
>> virtual_host=/ ssl=False>>>>, 'one_shot': True}
>> Calling <bound method LayerChannel._on_synchronous_complete of <
>> LayerChannel number=1 OPENING conn=<LayerConnection OPEN socket=(
>> '127.0.0.1', 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq
>> port=5672 virtual_host=/ ssl=False>>>> for "1:Channel.OpenOk"
>> 0 blocked frames
>> Calling <bound method LayerChannel._on_openok of <LayerChannel number=1
>> OPENING conn=<LayerConnection OPEN socket=('127.0.0.1',
>> 34690)->('127.0.0.1', 5672) params=<URLParameters host=rabbitmq port=5672
>> virtual_host=/ ssl=False>>>> for "1:Channel.OpenOk"
>> Entering blocking state on frame <Exchange.Declare(['arguments={}',
>> 'auto_delete=False', 'durable=False', 'exchange=dead-letters',
>> 'internal=False', 'nowait=False', 'passive=False', 'ticket=0',
>> 'type=fanout'])>; acceptable_replies=[<class
>> 'pika.spec.Exchange.DeclareOk'>]
>> Adding on_synchronous_complete callback
>> Added: {'arguments': None, 'only': None, 'calls': 1, 'callback': <bound
>> method LayerChannel._on_synchronous_complete of <LayerChannel number=1
>> OPEN conn=<LayerConnection OPEN socket=('127.0.0.1', 34690)->('127.0.0.1'
>> , 5672) params=<URLParameters host=rabbitmq port=5672 virtual_host=/ ssl=
>> False>>>>, 'one_shot': True}
>>
>> --
>> 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 [email protected] <javascript:>.
>> To post to this group, send email to [email protected]
>> <javascript:>.
>> 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/38e740e9-6b6e-4efb-92f6-8e23c0aa6252%40googlegroups.com
>>
>> <https://groups.google.com/d/msgid/django-users/38e740e9-6b6e-4efb-92f6-8e23c0aa6252%40googlegroups.com?utm_medium=email&utm_source=footer>
>> .
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
--
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 [email protected].
To post to this group, send email to [email protected].
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/7d4f18cb-6b64-4402-96fb-c053914934f0%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
