我有一个名为modelling-manager 的flask 应用程序正在运行,它正在接收来自另一个flask 应用程序的post 请求。直到那里一切正常。(所有文件都在同一个文件夹中)
Modeling-manager 在被 post 请求触发时会在 Redis 中注册一个作业以供工作人员执行。要执行的作业称为 run_model(),它存储在 main.py(flask 应用程序)中的不同文件和导入器中
worker 与modeling-manager 应用程序在同一个docker 上启动。使用脚本:worker.py
main.py -> 烧瓶应用程序
from flask import Flask, request, jsonify
import logging as lg
from datetime import datetime as dt
import os
import boto3
import redis
import json
from rq import Worker, Queue, Connection
from .model import run_model
app = Flask(__name__)
@app.route('/ModelManager/register', methods=['POST'])
def register_philjob_to_queue():
lg.info("triggered register cahce on model manager")
job_data = request.get_json()
lg.info("json data " + job_data["InstanceNumber"])
try:
with Connection(redis.Redis(host="redis-caching", port="6379")): …Run Code Online (Sandbox Code Playgroud)