Я работаю над приложением фляги, которое постоянно проверяет новые сообщения из очереди AWS SQS и получает их. Для этого я написал функцию, которая может запускаться конечной точкой. - /start
. Для простоты в коде я не опубликовал всю логику получения сообщений из очереди SQS. Просто напечатайте дату и время ожидания в течение 3 секунд.
Как сделать так, чтобы эта конечная точка работала, как только сервер фляги будет готов и будет обслуживать запросы?
Есть ли декоратор иличто-нибудь, чтобы сделать это возможным?
quque_services.py:
from datetime import datetime
import time
def receive_messages():
print(datetime.now())
time.sleep(3)
__ init__.py:
from flask import Flask, request, jsonify
from app.workload.services.queue_services import receive_messages
def create_app(**kwargs):
app = Flask(__name__, **kwargs)
@app.route('/start')
def queue_receiver():
while True:
receive_messages()
return app
wsgi.py:
from app import create_app
application = create_app()
if __name__ == "__main__":
application.run()