More specifically, it is logging:
None - - [12/Dec/2017:20:*06:39*] "WSCONNECTING /ws/" - -
DEBUG Upgraded connection daphne.response.HKlOHkryrd!VaSFKIooRZ to
WebSocket daphne.response.HKlOHkryrd!XdRRyyAyVn
DEBUG WebSocket closed for daphne.response.HKlOHkryrd!XdRRyyAyVn
None - - [12/Dec/2017:20:*06:43*] "WSDISCONNECT /ws/" - -
On Tuesday, December 12, 2017 at 2:11:44 PM UTC-5, Filbert wrote:
>
> 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/965cc9d8-4694-4342-af2f-06f02604d95a%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
