В основном у меня есть приложение фляги, которое размещено на экземпляре Azure. когда я публикую некоторые данные в конечной точке API, сельдерей запускает процесс в фоновом режиме, и API немедленно отправляет ответ клиенту.
вот базовый пример tasks.py:
from celery import Celery
app = Celery('tasks', broker ='amqp://localhost//')
@app.task
def reverse(main):
return main[::-1]
Ошибка:
Базовая колба Пример:
from flask import Flask
from flask import request
from tasks import *
app = Flask(__name__)
@app.route('/params',methods =['POST'])
def get_url():
main = request.args.get('main')
reverse.delay(main)
return main
if __name__ == "__main__":
app.run()
снова, приложение фляги запущено на экземпляре Azure. я должен изменить localhost на
IP в tasks.py