如何在 Python 中使用 PyCharm 进行 Celery 中的调试

要在 PyCharm 中使用 Celery 进行调试，需要按照以下步骤进行设置：

1. 在项目中安装 Celery 和 Redis（或其他支持的中间件）。可以使用以下命令在虚拟环境中安装：

pip install celery redis

2. 在 PyCharm 中创建一个新配置（Run Configurations），选择“Celery”，并填写以下信息：

• Script path：Celery 的启动脚本路径（通常为项目目录下的“celery.py”文件）
• Module name：Celery 的配置模块名称（通常为项目目录下的“celery_config”文件）
• Additional arguments：其他参数，如“-l info”表示记录信息级别为“info”的日志。

3. 在 Celery 配置文件中添加以下内容：

app.conf.update(
    BROKER_URL='redis://localhost:6379/0',
    CELERY_RESULT_BACKEND='redis://localhost:6379/0'
)

其中，“BROKER_URL”指定使用 Redis 作为任务队列，而“CELERY_RESULT_BACKEND”指定使用 Redis 存储任务结果。

4. 在项目中编写 Celery 任务代码，例如：

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')

@app.task
def add(x, y):
    return x + y

if __name__ == '__main__':
    result = add.delay(4, 4)
    print(result.get())

以上代码定义了一个名为“add”的任务，传入两个参数并返回它们的和。在最后一行代码中，我们启动了 Celery 并运行了“add”任务。

5. 启动 Celery 服务。可以使用以下命令在终端中启动：

celery -A tasks worker -l info

其中，“-A”指定了 Celery 应用的名称，“-l”指定日志级别。

6. 启动 PyCharm 中的调试，等待执行完成并查看结果。

以上示例中，如果要使用字符串作为范例，请将“add”函数的代码修改如下：

@app.task
def add(x, y, string="pidancode.com"):
    return f"{string}: {x + y}"

这里我们添加了一个默认字符串参数“string”作为范例，如果不传入参数，则使用默认值“pidancode.com”。在调用该任务时，可以使用以下代码：

result = add.delay(4, 4, "皮蛋编程")

这将传入参数“4”和“4”，并使用字符串“皮蛋编程”作为参数“string”的值，返回“皮蛋编程: 8”。