Djangoチャンネルのメッセージがすぐに送信されるようにするにはどうすればよいですか？

Question

考え方は、worker.connectワーカーでバックグラウンドタスクを実行することです。タスクの実行中に、通知グループを介して接続されたクライアントにその進捗状況を送信したいと思います。

問題：通知グループに送信されるメッセージは、作業者のタスクが終了するまで遅延します。したがって、5秒の遅れ（sleep(5)）の後に、クライアントで両方のメッセージ 'Start'と 'Stop'が同時に表示されます。私は、メッセージ 'Stop'に続いて5秒の遅延が続く 'Start'というメッセージを期待しています。なぜこれが当てはまらないのでしょうか？

私は、次の3つのプロセスが実行されている：

• daphne tests.asgi:channel_layer
• python manage.py runworker --exclude-channel=worker.connect
• python manage.py runworker --only-channel=worker.connect

views.pyで：

def run(request, pk): 
    Channel('worker.connect').send({'pk': pk}) 
    return HttpResponse(status=200) 

consumers.pyで：

def ws_connect(message): 
    Group('notifications').add(message.reply_channel) 
    message.reply_channel.send({"accept": True}) 

def worker_connect(message): 
    run_channel(message) 

views.pyで：

def run_channel(message): 
    Group('notifications').send({'text': 'Start'}) 
    sleep(5) 
    Group('notifications').send({'text': 'Stop'}) 

routing.py

channel_routing = { 
    'websocket.connect': consumers.ws_connect, 
    'worker.connect': consumers.worker_connect, 
} 

Answer 1

あなたはsend関数の引数としてimmediately=Trueを追加することができます。出典によると：

消費者が完了するまで送信されます。これを上書きするには、即時= Trueを渡すことができます。

https://github.com/django/channels/blob/master/channels/channel.py#L32