zoukankan      html  css  js  c++  java
  • celery定时任务

    from celery import Celery
    from datetime import timedelta
    
    app = Celery('gx', broker='redis://localhost:6379/1')
    app.conf.update(
        CELERYBEAT_SCHEDULE={
            'perminute': {
                'task': 'gx.add',
                'schedule': timedelta(seconds=5),
                'args': (1, 2)
            }
        }
    )
    
    
    @app.task
    def add(a, b):
        print(a+b)
    

      先启动worker:celery -A proj worker -l info -f=test.log  (-f指定的是日志输出位置)

      然后启动beat:celery -A proj beat

    beat发起定时任务worker执行定时任务

  • 相关阅读:
    USB
    Google
    机型参数
    mac
    反编译
    xcode
    Ios 消息推送
    真机:特殊
    Android
    object-c
  • 原文地址:https://www.cnblogs.com/ymy124/p/6433538.html
Copyright © 2011-2022 走看看