Celery + Flask 使用 SQLite 作为代理，调用任务时出错答案

【问题标题】：Celery + Flask with SQLite as broker, error when calling taskCelery + Flask 使用 SQLite 作为代理，调用任务时出错
【发布时间】：2018-09-30 17:39:53
【问题描述】：

我正在尝试让 Flask 与以 SQLite 作为后端的 Celery 一起工作。但是，使用以下代码：

CELERY_BROKER_URL = 'sqla+sqlite:///' + os.path.join(basedir, 'celery.db')

def make_celery(app):
    celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
    celery.conf.update(app.config)
    TaskBase = celery.Task
    class ContextTask(TaskBase):
        abstract = True
        def __call__(self, *args, **kwargs):
            with app.app_context():
                return TaskBase.__call__(self, *args, **kwargs)
    celery.Task = ContextTask
    return celery

启动worker后，I get this error when trying to call a dummy task:

error: [Errno 10061] No connection could be made because the target machine actively refused it

代码：

@app.route('/test')
def test():
    t = add_together.delay(100,200)
    return str(t.wait())

怎么了？我试过用谷歌搜索 Sqllite/SQLAlchemy/Flask/Celery 的任何组合，但一直找不到解决方案。

【问题讨论】：

Google 使用拼写 SQLite 而不是 Sqllite。

标签： python celery

【解决方案1】：

正如您在跟踪中看到的，您的应用仍在尝试连接到 rabbitmq-server。这意味着它没有正确配置。我不明白你为什么使用CELERY_BROKER_URL 而不是BROKER_URL。快速解决方案可能是，改变这个：

celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])

到

celery = Celery(app.import_name,
                broker='sqla+sqlite:///' + os.path.join(basedir, 'celery.db'),
                backend='db+sqlite:///' + os.path.join(basedir, 'celery_results.db'))

让我们看看它是如何工作的

【讨论】：

【解决方案2】：

error: [Errno 10061] No connection could be made because the target machine actively refused it

该错误通常意味着目标端口不可用或被某种防火墙阻止。

File "C:\Users\Robus\banking_virtenv\lib\site-packages\amqp\transport.py", line 95, in __init__
        raise socket.error(last_err)
    error: [Errno 10061] No connection could be made because the target machine actively refused it

看起来它正在尝试使用 AMQP 传输进行连接。请检查您的配置。

【讨论】：

正确，我理解错误。但是，它不应该尝试使用 sqlite 数据库吗？还是我错过了什么？
@Robus 这也是我的问题。它应该尝试使用 SQLite，而不是 AMQP。所以问题可能在于你如何配置 Celery。