Flask APScheduler + Gunicorn рабочие - все еще выполняет задачу дважды после исправления сокета - PullRequest
Новая
       45

Flask APScheduler + Gunicorn рабочие - все еще выполняет задачу дважды после исправления сокета

0 голосов
/ 14 ноября 2018

У меня есть приложение Flask, в котором я использую Flask-APScheduler для запуска запланированного запроса к моей базе данных и отправки электронного письма через задание cron.

Я запускаю свое приложение через Gunicorn со следующей конфигурацией и управляю через супервизор: 

[program:myapp]
command=/home/path/to/venv/bin/gunicorn -b localhost:8000 -w 4 myapp:app --preload
directory=/home/path/here
user=myuser
autostart=true
autorestart=true
stopasgroup=true
killasgroup=true

Данные о работе хранятся в моем config.py:

...config stuff
JOBS = [
    {
        'id': 'sched_email',
        'func': 'app.tasks:sched_email',
        'trigger': 'cron',
        'hour': 9,
    },
]
SCHEDULER_API_ENABLED = True

Первоначально электронное письмо отправлялось 4 раза из-за того, что 4 рабочих инициализировали приложение и планировщик. Я нашел похожую статью, в которой предлагалось открыть сокет при инициализации приложения, чтобы другие работники не могли получить работу.

My init .py: 

# Third-party imports
import logging
from logging.handlers import SMTPHandler, RotatingFileHandler
import os
from flask import Flask
from flask_mail import Mail, Message
from flask_sqlalchemy import SQLAlchemy
from flask_apscheduler import APScheduler
from flask_migrate import Migrate
from flask_login import LoginManager
import sys, socket

# Local imports
from config import app_config

# Create initial instances of extensions
mail = Mail()
db = SQLAlchemy()
scheduler = APScheduler()
migrate = Migrate()
login_manager = LoginManager()

# Construct the Flask app instance
def create_app(config_name):
    app = Flask(__name__)
    app.config.from_object(app_config[config_name])
    app_config[config_name].init_app(app)

    migrate.init_app(app, db)
    mail.init_app(app)
    db.init_app(app)

    # Fix to ensure only one Gunicorn worker grabs the scheduled task
    try:
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        sock.bind(("127.0.0.1", 47200))
    except socket.error:
        pass
    else:
        scheduler.init_app(app)
        scheduler.start()

    login_manager.init_app(app)
    login_manager.login_message = "You must be logged in to access this page."
    login_manager.login_message_category = 'danger'
    login_manager.login_view = "admin.login"

    # Initialize blueprints
    from .errors import errors as errors_blueprint
    app.register_blueprint(errors_blueprint)

    from .main import main as main_blueprint
    app.register_blueprint(main_blueprint)

    from .admin import admin as admin_blueprint
    app.register_blueprint(admin_blueprint)

    # Setup logging when not in debug mode
    if not app.debug:
        ... logging email config

        ... log file config

    return app

Теперь письмо отправляется дважды!

Кто-нибудь может подсказать, почему это происходит? Есть ли какие-нибудь журналы, в которые я могу погрузиться, чтобы понять, что происходит?

Я также читал об использовании декоратора @ app.before_first_request, но поскольку я использую шаблон фабрики приложений, я не уверен, как это включить.

Спасибо!

1 Ответ

0 голосов
/ 17 ноября 2018

Получается, что это была глупая ошибка, которую я допустил.

Я не настроил супервизор правильно, поэтому мой флаг --preload на самом деле не применялся.

После того, как я установил супервизор и перезагрузил, моя задача теперь работает правильно, и я получаю одно письмо.

Я надеюсь, что мои настройки выше помогут другим, так как я начинающий, мне потребовалось много времени, чтобы начать работать.

...