Re: Channels: starting Daphne in production

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 <tim...@gmail.com> 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 django-users...@googlegroups.com.
To post to this group, send email to django...@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/38e740e9-6b6e-4efb-92f6-8e23c0aa6252%40googlegroups.com.
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 django-users+unsubscribe@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/7d4f18cb-6b64-4402-96fb-c053914934f0%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.