djangoのカスタムコマンドでasyncioを使いたい

Question

djangoのカスタムコマンドでasyncioを使ってwebsocketによりデータを取得したいと思っています。
djangoを使う理由は、ORMを使っているからということとwebsocketで入手したデータをwebアプリとして活用したいからということです。

　HPの説明からhundleメソッドにloopを入れ込む形で作ってみましたが、全くデータを受信できませんでした。

　setting.pyに以下の文も追加しました。
os.environ["DJANGO_ALLOW_ASYNC_UNSAFE"] = "true"

　原因がわかる方がいらっしゃいましたら、ご意見をお願いします。

import asyncio
import json
import websockets

class Command(BaseCommand):

    def handle(self, *args, **kwargs):
            """ループの開始"""
            loop = asyncio.get_event_loop()
            loop.create_task(self.stream())
            try:
                loop.run_forever()
            except KeyboardInterrupt:
                exit()

    async def stream(self):
        uri = 'ws://localhost:18081/****/websocket'

        async with websockets.connect(uri, ping_timeout=None) as ws:
            while not ws.closed:
                response = await ws.recv()
                content = json.loads(response)

                score = self.original_method1(kwargs)
                print('reveiving')

                self.original_method2(kwargs)

Answer 1

Djangoのカスタムコマンドである必要はなさそうですね。
任意のプログラムからDjangoで作成しているモデルが呼び出せ、利用できます。

参考としてはこのへんのページが参考になると思います。
下記は例です。

import django
sys.path.append("/var/www/app") #manage.pyのある場所
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings') #settings.py
django.setup()

from appname import models #モデルのインポート

Comments

[taro_yamada]

ご回答ありがとうございます！
全然知らなかったです。今後活用していきます。