我正在使用开放语义搜索 (OSS),我想使用Flower 工具监视其进程。Celery 需要的工人应该在其网站上作为 OSS 状态给出
工作人员将执行诸如分析和索引排队文件之类的任务。工作进程由 etl/tasks.py 实现,并会在启动时由服务 opensemanticsearch 自动启动。
这个tasks.py文件如下所示:
#!/usr/bin/python3
# -*- coding: utf-8 -*-
#
# Queue tasks for batch processing and parallel processing
#
# Queue handler
from celery import Celery
# ETL connectors
from etl import ETL
from etl_delete import Delete
from etl_file import Connector_File
from etl_web import Connector_Web
from etl_rss import Connector_RSS
verbose = True
quiet = False
app = Celery('etl.tasks')
app.conf.CELERYD_MAX_TASKS_PER_CHILD = 1
etl_delete = Delete()
etl_web = …Run Code Online (Sandbox Code Playgroud)