Как запустить функцию в качестве фонового потока в приложении фляги uwsgi? - PullRequest
Новая
       6

Как запустить функцию в качестве фонового потока в приложении фляги uwsgi?

0 голосов
/ 05 июня 2018

Я хочу реализовать функцию (update_cert () в приведенном ниже коде), которая будет извлекать данные от третьей стороны (публичный сертификат) и записывать их в файл или БД.Эти данные предназначены для использования моим приложением-флягой (для проверки подписи маркеров доступа).

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

Я пытался реализовать эту функцию в планировщике в моем app.py.Но uWSGI будет вызывать его несколько раз во время инициализации каждого работника.Я боюсь, что это оставит мое приложение небезопасным.

Что было бы правильным способом реализации этой концепции.Ниже мой app.py. 

import os
from flask import Flask
from flask_restful import Api
from resources.user import UserRegister
from resources.matchingJob import MatchingJob
from resources.client import Client
from models.configs import ConfigModel


app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = os.environ.get('DATABASE_URL')
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

api = Api(app)

api.add_resource(UserRegister, '/register')
api.add_resource(MatchingJob, '/job', '/job/<string:matching_uuid>')
api.add_resource(Client, '/client', '/client/<string:matching_uuid>')


@app.before_first_request
 def update_cert():
    url_to_get_cert = <url>
    trust_path = '/etc/pki/tls/certs/ca-bundle.crt'
    cert = requests.get(url_to_get_cert, verify=trust_path).text
    cls.update('CERT', cert)

1 Ответ

0 голосов
/ 01 октября 2018

Попробуйте запустить Thread с выполнением update_cert, а затем time.sleep(seconds) (как вы сказали, вы хотите, чтобы это запускалось на протяжении всего жизненного цикла приложения, поэтому я понимаю, что вы хотите его периодически), и запустите этот поток до того, каклиния app = Flask(__name__).

...