将signal与celery 结合的异步signal

保存触发此函数,然后调用异步消息队列

from lawyer_assistant.celery import app
from notifications.models import Notification
# 触发消息——提醒
@app.task
def meal_handler(sender, instance, created,is_asynchronous=False, **kwargs):  
  """   
 :param sender:   
 :param instance:    
 :param created:   
 :param kwargs:   
 :return:   
 """
from  ce.tasks import meal_handler
#律所保存触发此函数,然后调用异步消息队列
@receiver(post_save, sender=LawFirm)
def delay_to_save(sender, instance, created, **kwargs):   
    t = meal_handler.s(sender=sender, instance=instance,created=created,is_asynchronous=True)    
    t.delay()
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 转自: http://www.jianshu.com/p/486b0965c296 http://www.jia...
    demop阅读 3,919评论 1 21
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,854评论 18 139
  • 五十三:请解释 JavaScript 中 this 是如何工作的。1.方法调用模式当一个函数被保存为一个对象的属性...
    Arno_z阅读 595评论 0 2
  • 来源 RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控...
    jiangmo阅读 10,396评论 2 34
  • 41.多用派发队列,少用同步锁 在Objective-C中,如果有多个线程要执行同一份代码,那么有时可能会出问题。...
    Code_Ninja阅读 1,166评论 1 13