Celery - 版本历史

Eric：/* Docker */

2022-12-17T17:56:23Z

Docker

←上一版本		2022年12月17日 (六) 17:56的版本
第281行：		第281行：
	</syntaxhighlight>		</syntaxhighlight>
	定时任务需要启用celery beat，定时发送到任务队列。打开一个终端，使用<code>docker exec -it celery容器名称 celery -A tasks beat</code>命令使容器启动celery beat		定时任务需要启用celery beat，定时发送到任务队列。打开一个终端，使用<code>docker exec -it celery容器名称 celery -A tasks beat</code>命令使容器启动celery beat

			===常见错误===
			* docker-compose.yml中<code>build: ./ </code>时，如果Dockerfile中使用pip安装，可能出现<code>Failed to establish a new connection: [Errno -3] Try again')':</code>错误。
			将docker-compose.yml中<code>build: ./ </code>修改为：<syntaxhighlight lang="docker" >
			build:
			context: ./
			network: host
			</syntaxhighlight>

	==资源==		==资源==

Eric：/* Docker */

2022-12-17T17:16:32Z

Docker

←上一版本		2022年12月17日 (六) 17:16的版本
第226行：		第226行：
	app = Celery('tasks', broker='redis://redis:6379/0', backend='redis://redis:6379/0' )		app = Celery('tasks', broker='redis://redis:6379/0', backend='redis://redis:6379/0' )

			# 设置定时任务，每隔30秒执行一次add任务
			app.conf.beat_schedule = {
			'add-every-30-seconds': {
			'task': 'tasks.add',
			'schedule': 30.0,
			'args': (16, 16)
			},
			}

			# 注册异步任务
	@app.task		@app.task
	def add(x, y):		def add(x, y):
第270行：		第280行：
	add.delay(3,3)		add.delay(3,3)
	</syntaxhighlight>		</syntaxhighlight>
			定时任务需要启用celery beat，定时发送到任务队列。打开一个终端，使用<code>docker exec -it celery容器名称 celery -A tasks beat</code>命令使容器启动celery beat

	==资源==		==资源==

2022年12月17日 (六) 17:02 Eric

2022-12-17T17:02:15Z

@@ 第209行： / 第209行： @@
 |[https://github.com/mher/flower/blob/master/docker-compose.yml Github.com/mher/flower/：docker-compose.yml]
 }}
 ==资源==

2022年12月17日 (六) 08:58 Eric

2022-12-17T08:58:30Z

←上一版本		2022年12月17日 (六) 08:58的版本
第192行：		第192行：
	===Flower===		===Flower===

			====docker====
			使用docker compose可以快速搭建Flower测试环境，[https://github.com/mher/flower/blob/master/docker-compose.yml flower]官方有配置好的Celery + Flower + [[Redis]] + [[prometheus]] + [[grafana]]测试环境。以下配置Celery + Flower + [[Redis]]环境。

			项目结构：
			<syntaxhighlight lang="bash" >
			examples
			├── docker-compose.yml
			├── Dockerfile
			└── examples
			├── celeryconfig.py
			└── tasks.py

			</syntaxhighlight>

			{{了解更多
			\|[https://github.com/mher/flower/blob/master/docker-compose.yml Github.com/mher/flower/：docker-compose.yml]
			}}

	==资源==		==资源==

2022年12月17日 (六) 08:09 Eric

2022-12-17T08:09:24Z

←上一版本		2022年12月17日 (六) 08:09的版本
第98行：		第98行：
	== 配置 ==		== 配置 ==
	=== 概览 ===		=== 概览 ===
	配置一般写在单独的文件中。如果使用默认加载器，文件名称需要为celeryconfig.py。Celery 4.0 版引入了小写设置和重命名一些前缀，旧的配置命令将在Celery 5.0不可用。一个简单的配置文件：		配置一般写在单独的文件中。如果使用默认加载器，文件名称需要为celeryconfig.py。Celery 4.0 版引入了小写设置和重命名一些前缀，旧的配置命令将在Celery 6.0不可用。一个简单的配置文件：
	<syntaxhighlight lang="python">		<syntaxhighlight lang="python">
	# celery_task为项目目录，包含__init__.py、celeryconfig.py、task1.py、task2.py		# celery_task为项目目录，包含__init__.py、celeryconfig.py、task1.py、task2.py

2022年12月17日 (六) 06:22 Eric

2022-12-17T06:22:27Z

←上一版本		2022年12月17日 (六) 06:22的版本
第98行：		第98行：
	== 配置 ==		== 配置 ==
	=== 概览 ===		=== 概览 ===
	配置一般写在单独的文件中。如果使用默认加载器，文件名称需要为celeryconfig.py。Celery 4.0 版引入了小写设置和重命名一些前缀，旧的配置命令将在Celery 6.0不可用。一个简单的配置文件：		配置一般写在单独的文件中。如果使用默认加载器，文件名称需要为celeryconfig.py。Celery 4.0 版引入了小写设置和重命名一些前缀，旧的配置命令将在Celery 5.0不可用。一个简单的配置文件：
	<syntaxhighlight lang="python">		<syntaxhighlight lang="python">
	# celery_task为项目目录，包含__init__.py、celeryconfig.py、task1.py、task2.py		# celery_task为项目目录，包含__init__.py、celeryconfig.py、task1.py、task2.py
			# celery_task
			# ├── __init__.py
			# ├── celeryconfig.py
			# ├── task1.py
			# └── task2.py
	# 以下为celeryconfig.py文件内容：		# 以下为celeryconfig.py文件内容：

第185行：		第190行：
	\|[https://docs.celeryproject.org/en/stable/userguide/monitoring.html Celery 文档：监控和管理]		\|[https://docs.celeryproject.org/en/stable/userguide/monitoring.html Celery 文档：监控和管理]
	}}		}}
			===Flower===


	==资源==		==资源==
	===官网===		===官网===

2021年11月7日 (日) 16:37 Eric

2021-11-07T16:37:37Z

@@ 第156行： / 第156行： @@
 === 结果存储 ===
 ==资源==
 ===官网===

2021年10月22日 (五) 05:22 Eric

2021-10-22T05:22:47Z

←上一版本		2021年10月22日 (五) 05:22的版本
第64行：		第64行：
	! 示例		! 示例
	\|-		\|-
	\| 整数		\| 数字
	\| 表示秒		\| 表示秒
	\| <code>30.0</code> ~~每30秒运行一次~~		\| <code>30.0</code> 每30秒执行一次
	\|-		\|-
	\| [https://docs.python.org/dev/library/datetime.html#datetime.timedelta timedelta]		\| [https://docs.python.org/dev/library/datetime.html#datetime.timedelta timedelta]
	\| ~~Pythont的timedelta对象，~~<br />使用时需要导入timedelta：<code>from datetime import timedelta</code>		\| [[Python]]的timedelta对象，用于表示时间间隔。<br />使用时需要导入timedelta：<code>from datetime import timedelta</code>
	\|		\| <code>timedelta(seconds=30)</code> 每30秒执行一次
	\|-		\|-
	\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#crontab-schedules crontab]		\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#crontab-schedules crontab]
	\| 能够方便设置每天或每星期什么时间执行。<br />使用时需要导入crontab：<code>from celery.schedules import crontab</code>		\| 能够方便设置每天或每星期什么时间执行。<br />使用时需要导入crontab：<code>from celery.schedules import crontab</code>
	\| <code>crontab()</code> 每分钟执行 <br /><code>crontab(minute=0, hour=0</code> 每天0点0分执行<br /><code>crontab(hour=7, minute=30, day_of_week=1)</code> 每个周星期一早上7点30分执行		\| <code>crontab()</code> 每分钟执行 <br /><code>crontab(minute=0, hour=0)</code> 每天0点0分执行<br /><code>crontab(hour=7, minute=30, day_of_week=1)</code> 每个周星期一早上7点30分执行 <br /><code>crontab(minute=0, hour='*/6')</code> 每六个小时执行一次：午夜、早上 6 点、中午、下午 6 点 <br /><code>crontab(minute=0, hour='0,6,12,18')</code>同前面
	\|-		\|-
	\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#solar-schedules solar]		\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#solar-schedules solar]

2021年10月22日 (五) 03:33 Eric

2021-10-22T03:33:19Z

←上一版本		2021年10月22日 (五) 03:33的版本
第18行：		第18行：
	==入门==		==入门==
	===基本架构===		===基本架构===
			Celery架构是一种生产者消费者模型，生产者（调用异步任务或定时任务）将任务发送到消息中间件（[[Redis]]或[[RabbitMQ]]等），消费者（任务执行单元）从消息中间件读取执行。
	{{#drawio:celery架构}}		{{#drawio:celery架构}}

第153行：		第154行：
	\|}		\|}

	=== ~~后端存储~~ ===		=== 结果存储 ===

	==资源==		==资源==

2021年10月22日 (五) 03:07 Eric

2021-10-22T03:07:39Z

←上一版本		2021年10月22日 (五) 03:07的版本
第1行：		第1行：
	Celery是基于[[Python]]~~的一个开源的分布式实时任务队列工具，同时也支持任务调度。celery单词中文为芹菜。~~		Celery是基于[[Python]]的一个开源的分布式实时任务队列工具，同时也支持任务调度。

	==简介==		==简介==
	===时间轴===		===时间轴===
	*~~2009.04.24，Ask~~ Solem 发布Celery 0.1.0		*2009年04月24日，Ask Solem 发布Celery 0.1.0
	*~~2010.02.10，发布Celery~~ 1.0.0		*2010年02月10日，发布Celery 1.0.0
	*~~2016.11.04，发布Celery~~ 4.0.0。配置文件引入小写字母设置和重命名了一些前缀。		*2016年11月04日，发布Celery 4.0.0。配置文件引入小写字母设置和重命名了一些前缀。
	*~~2020.09.24，发布Celery~~ 5.0.0		*2020年09月24日，发布Celery 5.0.0
	*~~2021.06.18，发布Celery~~ 5.1		*2021年06月18日，发布Celery 5.1

	{{了解更多		{{了解更多
第16行：		第16行：
	pip install -U Celery		pip install -U Celery

	==~~基础知识~~==		==入门==
	===~~基本框架~~===		===基本架构===
			{{#drawio:celery架构}}

			===基本概念===
	{\| class="wikitable" style="width: 100%;		{\| class="wikitable" style="width: 100%;
	! 名称		! 名称
第29行：		第32行：
	\|}		\|}

	~~{{#drawio:celery架构}}~~		===示例 ===

	== 异步任务 ==		== 异步任务 ==
第40行：		第43行：
	}}		}}

			=== 定时 ===
			<code>schedule</code>用于设置执行的频率，可以是整数、timedelta、crontab、solar或自定义类型。一个示例：
			<syntaxhighlight lang="python">
			from celery.schedules import crontab

			beat_schedule = {
	=== ~~定时 ===~~		# 每个周星期一早上7点30分执行
			'add-every-monday-morning': {
			'task': 'tasks.task1',
			'schedule': crontab(hour=7, minute=30, day_of_week=1),
			'args': (16, 16),
			},
			}
			</syntaxhighlight>

	{\| class="wikitable" style="width: 100%;		{\| class="wikitable" style="width: 100%;
	! 类别		! 类别
	~~! 命令~~
	! 描述		! 描述
			! 示例
	\|-		\|-
			\| 整数
			\| 表示秒
			\| <code>30.0</code> 每30秒运行一次
			\|-
			\| [https://docs.python.org/dev/library/datetime.html#datetime.timedelta timedelta]
			\| Pythont的timedelta对象，<br />使用时需要导入timedelta：<code>from datetime import timedelta</code>
	\|		\|
	\|
	\|
	\|-		\|-
			\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#crontab-schedules crontab]
			\| 能够方便设置每天或每星期什么时间执行。<br />使用时需要导入crontab：<code>from celery.schedules import crontab</code>
			\| <code>crontab()</code> 每分钟执行 <br /><code>crontab(minute=0, hour=0</code> 每天0点0分执行<br /><code>crontab(hour=7, minute=30, day_of_week=1)</code> 每个周星期一早上7点30分执行
			\|-
			\| [https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#solar-schedules solar]
			\| 太阳时间表，按照日出、日落、黎明或黄昏来执行。<br />使用时需要导入solar：<code>from celery.schedules import solar</code> <br />格式：<code>solar(event, latitude, longitude)</code>
			\| <code>'schedule': solar('sunset', -37.81753, 144.96715)</code> 墨尔本日落时执行
			\|-
			\| 自定义
	\|		\|
	\|
	\|		\|
	\|}		\|}

Celery - 版本历史

Eric：​/* Docker */

Eric：​/* Docker */

2022年12月17日 (六) 17:02 Eric

2022年12月17日 (六) 08:58 Eric

2022年12月17日 (六) 08:09 Eric

2022年12月17日 (六) 06:22 Eric

2021年11月7日 (日) 16:37 Eric

2021年10月22日 (五) 05:22 Eric

2021年10月22日 (五) 03:33 Eric

2021年10月22日 (五) 03:07 Eric

Eric：/* Docker */

Eric：/* Docker */