如何将 Huey 连接到 Flask 应用程序

How to wire up Huey to a Flask application

我已经阅读了官方文档,但我不太确定我是否理解如何应用他们所说的内容。我也看过,我也用过工厂模式。就是看不到全貌。

  1. 连接池只要其他redis/huey设置可能因给定环境不同而不同(开发生产).我们如何连接 huey 以便我们可以像 Flask 应用程序一样配置它?

  2. 只要我理解从视图中触发任务,我们就需要导入任务模块并调用特定任务(调用传递敏感参数的函数)。我们应该在哪里实例化,保留 huey 实例?

  3. 任务应该知道应用程序的依赖关系吗?我们是否应该为此考虑另一个精简的 Flask 应用程序?

你能帮点忙吗?

下面是我如何连接所有内容。

首先,这是我的项目文件夹的内容:

  1. 获取一个精简的 Flask 应用程序以供您的任务使用。正如建议的那样 我创建了一个辅助应用程序工厂:

    # global dependencies
    db = SQLAlchemy()
    
    def create_app_huey(config_name):
    
        app = Flask(__name__)
    
        # apply configuration
        app.config.from_object(config[config_name])
    
        # init extensions
        db.init_app(app)
    
        return app
    
  2. 创建任务包。这里的两个重要文件是 config.pytasks.pyThis post helped a lot。让我们从配置开始。请注意,这是非常简单的方法。

    # config.py (app.tasking.config)
    
    import os
    from huey import RedisHuey
    
    
    settings__development = {
        'host': 'localhost'
    }
    
    settings__testing = {
        'host': 'localhost'
    }
    
    settings__production = {
        'host': 'production_server'
    }
    
    settings = {
        'development': settings__development,
        'testing': settings__testing,
        'production': settings__production,
        'default': settings__development
    }
    
    huey = RedisHuey(**settings[os.getenv('FLASK_ENV') or 'default'])
    

    那么 tasks.py 模块将如下所示:

    import os
    from app.tasking.config import huey
    from app import create_app_huey
    
    
    app = create_app_huey(config_name=os.getenv('FLASK_ENV') or 'default')
    
    
    @huey.task()
    def create_thumbnails(document):
        pass
    
  3. 运行 消费者。激活您的虚拟环境。然后 运行 来自 cmd (我在 Windows):

    huey_consumer.py app.tasking.config.huey

    其中 app.tasking.config 是一个 package.package.module 路径(在我的例子中!)和 huey 是可用的(在配置模块中)huey 实例的名称。检查您的 huey 实例名称。

    Reading this helped.