Celery / Flask / Redis - функция apply_asyn c не работает - Обновлено 2 - PullRequest
Новая
       43

Celery / Flask / Redis - функция apply_asyn c не работает - Обновлено 2

0 голосов
/ 29 января 2020

каждый. 

app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379/0'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379/0'

celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)


def upload():
    if checkDouble == None:
        do_async_upload.apply_async(args=[checkDouble], countdown=15)
        return 'Saved ' + file.filename
    else:
        return "File exists"    

@celery.task
def do_async_upload(pic):
    print("hello2")
    db.session.add(pic)
    db.session.commit()
    return 0

Но do_sync_upload не работает (hello2 не печатает), просто пропускает. Сервер Redis работает правильно

Обновлено: 

if checkDouble == None:
        print('Hello')
        async_result = do_async_upload.delay(checkDouble)
        print(async_result)
        result = async_result.get()


        return 'Saved ' + file.filename
    else:
        return "File exists"

Но do_async_upload.apply_asyn c не выполняется вообще. Может быть, проблема в моем Redis? Сервер работает, но после того, как я пытаюсь отправить что-то, получается от 0 до 4 подключенных клиентов. Или даже у меня проблема с настройками даты и времени.

ОБНОВЛЕНИЕ 2:

Я пробовал 2 разных примера с Flask и Celery, но ни один из них не работает. Сервер Redis показывает некоторую активность, но нет. Оба они используют одну и ту же функцию: Код из https://github.com/ro6ley/flask-celery-demo: 

@client.task
def send_mail(data):

    with app.app_context():
        msg = Message("Ping!",
                    sender="admin.ping",
                    recipients=[data['email']])
        msg.body = data['message']        
        mail.send(msg)


@app.route('/', methods=['GET', 'POST'])
def index():
    if request.method == 'GET':
        return render_template('index.html')

    elif request.method == 'POST':
        data = {}
        data['email'] = request.form['email']
        data['first_name'] = request.form['first_name']
        data['last_name'] = request.form['last_name']
        data['message'] = request.form['message']
        duration = int(request.form['duration'])
        duration_unit = request.form['duration_unit']
        print("1")    
        send_mail.apply_async(args=[data], countdown=duration)
        print("2")
        flash(f"Email will be sent to {data['email']} in {request.form['duration']} {duration_unit}")

Показывает сообщение fla sh, но сообщение не приходит. Config.py установлен правильно.

Следующее приложение: 

 @app.route('/', methods=['GET', 'POST'])
    def index():
        if request.method == 'GET':
            return render_template('index.html', email=session.get('email', ''))
        email = request.form['email']
        session['email'] = email

        # send the email
        email_data = {
            'subject': 'Hello from Flask',
            'to': email,
            'body': 'This is a test email sent from a background Celery task.'
        }
        if request.form['submit'] == 'Send':
            # send right away
            send_async_email.delay(email_data)
            flash('Sending email to {0}'.format(email))
        else:
            # send in one minute
            send_async_email.apply_async(args=[email_data], countdown=60)
            flash('An email will be sent to {0} in one minute'.format(email))

        return redirect(url_for('index'))

    @celery.task
    def send_async_email(email_data):
        """Background task to send an email with Flask-Mail."""
        msg = Message(email_data['subject'],
                      sender=app.config['MAIL_DEFAULT_SENDER'],
                      recipients=[email_data['to']])
        msg.body = email_data['body']
        with app.app_context():
            mail.send(msg)

Ни одна из опций не работает.

1 Ответ

0 голосов
/ 30 января 2020

apply_asyn c () возвращает объект AsyncResult НЕМЕДЛЕННО, поэтому неудивительно, что вы ничего не видите и думаете, что do_async_upload () не выполнено ...

Итак, я предлагаю вам сделать две вещи:

1) Измените upload () так, чтобы оно было примерно таким: 

async_result = do_async_upload.apply_async(args=[checkDouble], countdown=15)
# .get() blocks until the task is done and returns
result = async_result.get()

2) Не вызывайте print () в задачах Celery. Используйте функцию get_task_logger(), чтобы получить объект регистратора Celery и использовать его в своих задачах. Об этом в документации есть целый раздел .

...