可根据task_id过滤
以下是worker从redis队列中获取任务并执行任务的过程
未完请看第二章
Celery Django Redis Rest framework2.环境版本Django 3.2.12Django-celery-beat 2.2.1Django-celery-results 2.2.0Django-redis 4.8.0Djangorestframework 3.13.1Django-rest-swagger 2.2.0操作系统：Win10Redis版本：3.2.123.Celery配置
Celery文档参考：http://docs.jinkan.org/docs/celery/
参考文章：https://www.jb51.net/article/158046.htm
Django中异步任务—django-celery
Celery简单介绍：
celery使用场景：
耗时任务定时任务
请求结果不怎么重要的
耗时任务比如：发送短信验证码我们可以先发送给客户任务状态（请求成功或失败）
请求结果重要的建议使用django实现 比如：支付
首先简单介绍一下，Celery 是一个强大的分布式任务队列，它可以让任务的执行完全脱离主程序，甚至可以被分配到其他主机上运行。我们通
在运营系统中经常用到异步方式来处理我们的任务，比如将业务上线流程串成任务再写入队列，通过后台作业节点去调度执行。比较典型的案例为腾讯的蓝鲸、织云、云智慧等平台。本译文结合Django+Celery+Redis实现一个定期从Flickr获取图片并展示的简单案例，方便大家理解实现异步对列任务的过程。刚接触django的时候，我经历过的最让人沮丧的事情是需要定期运行一段代码。我写了一个需要每天上午12点执行一个动作的不错的函数。很简单是不是？错了。事实证明，这对我来说是一个巨大的困难点，因为，那时我使用Cpane类型的虚拟主机管理系统，它能专门提供一个很友好，很方便的图形用户界面来设置cron作业。
<script src="https://cdn.jsdelivr.net/npm/vue"></script>
2.django 和vue语法冲突处理需要增加一个标签{% verbatim %}
{% verbatim %}
<div id="app">
{{ text }} <br><br>
<button v-on:click="create_server"&..
0. Celery介绍
Celery是一个功能完备即插即用的异步任务队列系统。它适用于异步处理问题，当发送邮件、或者文件上传, 图像处理等等一些比较耗时的操作，我们可将其异步执行，这样用户不需要等待很久，提高用户体验。
简单，易于使用和维护，有丰富的文档。
高效，单个celery进程每分钟可以处理数百万个任务。
灵活，celery中几乎每个部分都可以自定义扩展。
总之一句话，快
一. 官方文档
中文文档http://docs.jinkan.org/docs/celery/getting-sta
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoProject.settings') # 设置django环境
app = Celery('DjangoProje...
### 回答1：
Django Celery 是一个用于 Django 项目的分布式任务队列，可以用来处理异步任务和定时任务。其中，定时任务可以通过 Celery Beat 来实现，它可以根据配置的时间间隔或者时间点来执行任务。Celery Beat 可以与 Celery Worker 配合使用，实现任务的异步执行。通过 Django Celery 和 Celery Beat，我们可以方便地实现定时任务，提高应用的性能和可靠性。
### 回答2：
Django celery 是一个 Python 应用程序框架，专门用于在后台运行分布式任务，有时也被称为分布式队列。在应用程序中，定时任务是一个非常常见的任务，Django celery 提供了一个强大的定时任务管理系统来解决这个问题。
Django celery 的定时任务是基于定时器和消息中间件构建的。它使用Celery Beat作为作业调度程序，并配合 Redis/RabbitMQ 等中间件实现消息队列。Django celery 的主要优点是：它是一个分布式的后台任务队列处理工具，可以把任务异步化，这样可以避免等待的时间，提高后台处理效率。
Django celery 提供了一个 Celery Beat 守护进程来提供定时任务的功能。它可以通过两种方式执行定时任务：
1. 周期性任务：这些任务在固定的时间间隔内按照预定义的计划运行。例如，我们可以计划在每小时的第15分运行一次任务，或在每天的某个时候运行一次任务。这些计划由 Celery Beat 系统维护并执行。我们可以通过在 Django 管理后台中录入任务来定义这些计划。
2. 延迟任务：这些任务在使用调度程序时不需要预定义计划。而是只需在需要执行任务时向 Celery 队列添加任务即可。这些任务可以通过一个延迟的任务调用来执行。例如，我们可以定义一个在应用程序中上传文件后执行的任务，或在发送电子邮件后执行一个任务。
Django celery 中定义的任务需要满足特定的格式，通常是一个 Python 函数，它可以接收任意数量的参数，这些参数可以是 Python 任何数据类型。独立的 Django celery 任务不需要与应用程序的其他部分通信，因此它们比定期执行的任务简单得多。要执行此任务，请将其添加到 Celery 消息队列中即可。
总之，采用 Django celery 可以轻松地实现定时任务，极大地提高系统的性能和效率。无论是周期性任务还是延迟任务，您都可以使用 Django celery 来轻松定义和调度它们。无论您是在创建 Web 应用程序、处理大量数据或执行任何其他任务，Django celery 都是一个非常有用的工具。
### 回答3：
Django celery 是一款流行的任务队列库，它提供的定时任务功能可以让你在特定的时间间隔内自动执行代码。这对于需要重复执行某些操作的应用程序来说非常有用。
要使用 Django celery 完成定时任务，需要按照以下步骤进行操作：
1. 安装 Django celery：可以通过 pip 命令来安装，具体命令如下：
pip install django-celery
2. 创建 celery 实例：在 Django 项目的根目录下，创建一个名为 celery.py 的文件，并在其中实例化 celery 应用程序，代码如下：
```python
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# 设置默认 DJANGO_SETTINGS_MODULE
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'yourapp.settings')
app = Celery('yourapp')
# 使用同一个文件配置celery和django环境
app.config_from_object('django.conf:settings', namespace='CELERY')
# 从所有已注册的app中加载任务模块
app.autodiscover_tasks()
3. 创建定时任务：在 Django 项目的某个应用下，创建一个名为 tasks.py 的文件，并在其中定义需要执行的任务，例如：
```python
from celery.decorators import periodic_task
from celery.task.schedules import crontab
@periodic_task(run_every=(crontab(minute='*/15')))
def my_task():
# 每15分钟执行一次的任务
print("Task executed at " + datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
4. 启动 worker 和 beat：在命令行中分别运行以下命令，分别启动 worker 和 beat：
$ celery -A yourapp worker -l info
$ celery -A yourapp beat -l info
5. 设置定时任务并运行：现在，你可以通过 Django celery 提供的定时任务管理界面来设置定时任务，也可以在代码中自定义任务的时间间隔，然后启动任务运行。
总的来说，Django celery 提供的定时任务功能可以使你的应用在特定的时间间隔内自动执行代码，从而提高应用的效率和可靠性。需要注意的是，在设计和实现定时任务时，应尽量考虑到并发性和数据一致性等实际问题，以确保任务运行的正确性和稳定性。
所以新手使用celery很仔细的建立文件夹名字、文件夹层级、python文件名字。
所以网上的celery博客教程虽然很多，但是并不能学会使用，因为要运行起来需要以下6个方面都掌握好，博客文字很难表达清楚或者没有写全面以下6个方面。
celery消费任务不执行或者报错NotRegistered，与很多方面有关系，如果要别人排错，至少要发以下6方面的截图，因为与一下6点关系很大。
1)整个项目目录结构, 2）@task入参 ,3）celery的配置，4）celery的配置 include ,5）cmd命令行启动参数 --queues= 的值,6）用户在启动cmd命令行时候，用户所在的文件夹。
在不规范的文件夹路径下，使用celery难度很高，一般教程都没教。
[项目文件夹目录格式不规范下的celery使用演示](https://github.com/ydf0509/celery_demo) 。
此国产分布式函数调度框架 funboost python万能通用函数加速器 https://funboost.readthedocs.io/ ，
从用法调用难度，用户所需代码量，超高并发性能，qps控频精确程度，支持的中间件类型，任务控制方式，稳定程度等19个方面全方位超过celery。发布性能提高1000%，消费性能提高2000%。
pip install funboost
