在 Django 中发送关于 post_save 信号的通知

Question

我有一个名为 deposit 的模型，我正尝试在 table 中添加新行时发送实时通知。是否可以使用 django-channels 这样做？

Answer 1

您可以简单地为 post_save

添加一个信号

@receiver(post_save, sender=Deposit)
def signal_deposit_save(sender, instance, created, **kwargs):
    if created: # This means it is a new row
        # Send notification using django-channels

Answer 2

您可以使用 Django 模型的 save 方法，如下所示：

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer

class Info(models.Model):
    # your model fields

    def save(self, force_insert=False, force_update=False, using=None,
             update_fields=None):
        super(Info, self).save(force_insert, force_update, using, update_fields)
        # send info to channel
        channel_layer = get_channel_layer()
        async_to_sync(channel_layer.group_send)(
            'infochannel',
            {
                'type': 'infochannel.message',
                'device_id': str(self.device_id)
            }
        )

在消费者中：

from channels.generic.websocket import AsyncWebsocketConsumer

class DataConsumer(AsyncWebsocketConsumer):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.group_name = ''

    async def connect(self):
        # we are using one fixed group
        self.group_name = 'infochannel'

        await self.channel_layer.group_add(
            self.group_name,
            self.channel_name
        )
        await self.accept()

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard('infochannel', self.channel_name)

    async def infochannel_message(self, event):
        # Send message to websocket group
        await self.send(text_data=event['device_id'])

其中device_id是我模型上的一个字段，当然你还要设置路由，redis_channels等等。

在 Django 中发送关于 post_save 信号的通知

Send notification on post_save signal in django

django

django-channels