我正在使用django频道构建一个web应用程序。我还有一个任务函数,我使用芹菜节拍定期运行(每30秒一次(。此任务函数每隔30秒将数据发送到我的web套接字。
现在,如果消费者加入我的渠道组,他必须等待一段时间,直到我的下一个数据到达。但我想要的是向新消费者展示我以前的数据,直到新的数据到来。所以我必须把以前的数据缓存在某个地方。
正确的方法是什么?我知道使用redis,但如何在django频道?
这很简单。要将数据附加到缓存,只需执行以下操作:
cache.set(<key>, <value>, <timeout>)
我希望它对你有用!。
如果使用AsyncConsumer,则应使用sync_to_async
包装器调用缓存方法:
await sync_to_async(cache.set)(<key>, <value>, <timeout>)