Django Celery定时任务

菜小白
  • 32

在windows下使用pycharm 怎么使用django-celery
def API():

data_list = {
    'sid': parameter.sid,
    'nonce': parameter.nonce,
    'timestamp': parameter.timestamp,
    'signature': parameter.signature,
    'start_date': parameter.start_time,  # starttime
    'over_date': parameter.over_time}
statistical_api = requests.get("‘接口’).json()
statistical_data = statistical_api.get('data')
for sj in statistical_data:
    statistical_list = statistical_data.get(sj)
    for qd in statistical_list:
        data = statistical_list.get(qd)
        tj = Statistical.objects.all()
        matching = tj.filter(create_time=sj, channel_id=qd)
        if not matching:
            print("数据不存在,添加添加数据中ing....")
            Statistical.objects.create(username=sj)
        else:
            print("数据已存在,数据更新中ing....")
            matching.update(username=sj)
return HttpResponse("请求统计存储成功!!")

这个是一个获取接口数据的代码 我想每隔5分钟执行一次 因为这种获取数据接口我有多个所有希望是多线程和非阻塞的并且我是准备在windows上本地运行的
之前我也使用了apscheduler 但是我使用的是使用装饰器来定时 每次运行后整个项目就只运行定时任务去了
例如:
@sched.interval_schedule(seconds=60)  
      
    def mytask():  
      
        chekUserFiles()  
      
    sched.start  
回复
阅读 2.8k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
宣传栏