我想通過 websocket 從數據庫流式傳輸數據?；旧厦棵腌姸紩幸粭l新記錄被插入到 DataModel 中，我想在插入后立即通過 websocket 發送這條新記錄。有人建議我在調用模型的 save() 方法時使用信號。所以在我的 models.py 中添加了這個：def save_post(sender, instance, **kwargs): print('signal')post_save.connect(save_post, sender=DataModel)save_post我應該在我的 consumers.py里面和上面放什么，以便數據通過？
1 回答
楊__羊羊
TA貢獻1943條經驗 獲得超7個贊
您首先必須使用以下代碼連接到您的 Django 通道層：
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
channel_layer = get_channel_layer()
data = <your-data> # data you want to send
async_to_sync(channel_layer.group_send(<group_name>, {
"type": "notify",
"message": data
}))
它會將您連接到您在設置文件中定義的默認后端層：
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {
"hosts": [("localhost", 6379)],
},
},
}
并將在您的班級中為擁有該組的所有用戶調用一個名為notify（函數名稱是您的選擇）的函數Consumer<group_name>
async def notify(self, event):
data = event["message"]
# here you can do whatever you want to do with data
有關更多信息，您可以在此處獲得工作示例：https ://channels.readthedocs.io/en/latest/tutorial/part_2.html#enable-a-channel-layer
添加回答
舉報
0/150
提交
取消