Also, curiously, when I use Inmemory, it seems to connect and immediately
disconnect. Hopefully my Nginx conf makes sense.
location /ws {
proxy_pass http://unix:/tmp/daphne.ws;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_http_version 1.1;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header Host $host;
}
On Tuesday, December 12, 2017 at 2:01:18 PM UTC-5, Filbert wrote:
>
> 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]> 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,<span style="color:#000"
>>>
>>
--
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/3bbc28b5-d5d9-4b94-8c4d-12b4a5cd9b38%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
