在Python中，一种在多进程中，利用标签向进程分享全局变量，且开放Web接口的方法




```python
import base64
import os
import time
import traceback
import cv2
from multiprocessing import Manager, Process
import uvicorn
from fastapi.middleware.cors import CORSMiddleware
from fastapi import FastAPI, File, Form, UploadFile
import requests
model_config = {
    "process_N": 1,
    "port": 8099,
    "FastAPIWorks": 1  # must be number 1
}
app = FastAPI(
    title='FastAPI',
    description='FastAPI',
    version='1.0.0',
    docs_url='/docs',
    redoc_url='/redocs',
)
app.add_middleware(
    CORSMiddleware,
    allow_origins=["*"],
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)
updatelabel = 1
def get_db():
    global updatelabel
    updatelabel += 1
    table = "i am table" + str(updatelabel)
    return {"updatelabel": updatelabel, "table": table}
camera_info = Manager().list()
camera_info.append(get_db())
@app.get("/emq/")
def alg_analyse_bytes(a: int):
    if a == 1:
        camera_info[0] = get_db()
    return "ok"
@app.post("/init_process/")
def init_process(process_num: int = Form(...), passwd: str = Form(...)):
    if passwd == "woshimima":
        if process_num <= 8:
            for i in range(process_num):
                Process(target=deal_picture, args=(camera_info,)).start()
    return 1
def deal_picture(camera_info):
    camera_info_copy = dict(camera_info[0]).copy()
    while True:
        try:
            if camera_info_copy["updatelabel"] != camera_info[0]["updatelabel"]:
                camera_info_copy = dict(camera_info[0]).copy()
            # gogogo
            print(camera_info_copy)
        except:
            traceback.print_exc()
def cv2_to_base64(image):
    base64_str = cv2.imencode('.jpg', image)[1].tostring()
    base64_str = base64.b64encode(base64_str)
    return base64_str
def init_model():
    time.sleep(1)
    requests.post("http://0.0.0.0:" + str(model_config["port"]) + "/init_process",
                  data={"process_num": model_config["process_N"],
                        "passwd": "woshimima"})
    print(f"algorithm already start ")
if __name__ == '__main__':
    modulename = os.path.basename(os.path.abspath(__file__)).split(".")[0]
    Process(target=init_model).start()
    uvicorn.run(modulename + ':app',
                host='0.0.0.0',
                port=model_config["port"],
                reload=False,
                debug=False,
                workers=model_config["FastAPIWorks"])
```

Python 多进程中 分享全局变量

谁能想到，dolphinscheduler 报这个是因为调用命令写错了呢？





```
2021-11-11 14:37:15.520 - ShellTask.java:92 - INFO - shell task params {"rawScript":"/home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python /home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python nation_fire_update_forcast.py","localParams":[],"resourceList":[{"res":"nation_fire_update_forcast.py"},{"res":"util_nrisk.py"}]}
2021-11-11 14:37:15.521 - ShellTask.java:151 - INFO - raw script : /home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python /home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python nation_fire_update_forcast.py
2021-11-11 14:37:15.521 - ShellTask.java:152 - INFO - task dir : /home/dolphinscheduler-master/exec/process/1/30/36810/37102
2021-11-11 14:37:15.521 - ShellCommandExecutor.java:99 - INFO - tenantCode user:dolphinscheduler, task dir:30_36810_37102
2021-11-11 14:37:15.521 - ShellCommandExecutor.java:103 - INFO - create command file:/home/dolphinscheduler-master/exec/process/1/30/36810/37102/30_36810_37102.command
2021-11-11 14:37:15.521 - ShellCommandExecutor.java:116 - INFO - command : #!/bin/sh
BASEDIR=$(cd `dirname $0`; pwd)
cd $BASEDIR
source /home/dolphinscheduler/data1_1T/dolphinscheduler/conf/env/dolphinscheduler_env.sh
/home/dolphinscheduler-master/exec/process/1/30/36810/37102/30_36810_37102_node.sh
2021-11-11 14:37:15.522 - AbstractCommandExecutor.java:329 - INFO - task run command:
sudo -u dolphinscheduler sh /home/dolphinscheduler-master/exec/process/1/30/36810/37102/30_36810_37102.command
2021-11-11 14:37:15.526 - AbstractCommandExecutor.java:158 - INFO - process start, process id is: 1764
2021-11-11 14:37:15.557 - AbstractTask.java:106 - INFO -  ->   File "/home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python", line 1
 SyntaxError: Non-UTF-8 code starting with '\xa1' in file /home/dolphinscheduler/miniconda3/envs/py37kevin/bin/python on line 2, but no encoding declared; see http://python.org/dev/peps/pep-0263/ for details
2021-11-11 14:37:15.558 - AbstractCommandExecutor.java:168 - INFO - process has exited, work dir:/home/dolphinscheduler-master/exec/process/1/30/36810/37102, pid:1764 ,exitStatusCode:1
```

SyntaxError: Non-UTF-8 code starting with ‘\xa1‘ in file /home/dolphinscheduler

# ClickHouse 





下面2句话，上一句话可以看看将要删除的数据，下一句话直接删除这些数据。
```sql
select * from cl_grid_fwi_forecast_hourly_data cgffhd  where update_time  = '2021-10-28 22:00:00';
ALTER  table cl_grid_fwi_forecast_hourly_data delete  where update_time  = '2021-10-28 22:00:00';
```

# Mysql 
```sql
DELETE FROM forest_fire_chongli.alg_national_fire_risk_current_hourly_data where data_time='2021-12-23 00:00:00';
```

ClickHouse 数据库 删除表中数据 Mysql 删除数据

Python





```
        norm = np.sqrt(np.sum(emb*emb)+0.00001)
        emb /= norm
```

特征向量归一化 Python

最开始加这几句程序：




```python
from pylab import mpl
mpl.rcParams['font.sans-serif'] = ['FangSong']  # 指定默认字体
mpl.rcParams['axes.unicode_minus'] = False  # 解决保存图像是负号'-'显示为方块的问题
```

matplotlib Pythoh 如何显示中文

我是一个专注技术分享的博主,尤其爱搞深度学习和单片机电子。你现在看到的是我的个人博客网站。