Python





```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()
            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中，一种在多进程中，利用标签向进程分享无冲突全局变量，且开放Web接口的方法

参考：[https://zhuanlan.zhihu.com/p/143009848](https://zhuanlan.zhihu.com/p/143009848)





鼠标移至标题栏–>单击鼠标右键–>属性–>取消勾选快速编辑模式


![在这里插入图片描述](/static/img/images/00175.png)

windows cmd 执行程序卡住不动 需要回车 假死现象

实现将文件放入windows剪切板功能。






C++:

```C++
#include <iostream>
#include <windows.h>
#include <shlobj.h>
int CopyFileToClipboard(char szFileName[]);
int main()
{
 CopyFileToClipboard("C:\\Users\\Administrator\\Desktop\\test\\hello.txt");
 return 0;
}
int CopyFileToClipboard(char szFileName[])
{
 UINT uDropEffect;
 HGLOBAL hGblEffect;
 LPDWORD lpdDropEffect;
 DROPFILES stDrop;
 HGLOBAL hGblFiles;
 LPSTR lpData;
 uDropEffect = RegisterClipboardFormat("Preferred DropEffect");
 hGblEffect = GlobalAlloc(GMEM_ZEROINIT | GMEM_MOVEABLE | GMEM_DDESHARE, sizeof(DWORD));
 lpdDropEffect = (LPDWORD)GlobalLock(hGblEffect);
 *lpdDropEffect = DROPEFFECT_COPY;//复制; 剪贴则du用DROPEFFECT_MOVE
 GlobalUnlock(hGblEffect);
 stDrop.pFiles = sizeof(DROPFILES);
 stDrop.pt.x = 0;
 stDrop.pt.y = 0;
 stDrop.fNC = FALSE;
 stDrop.fWide = FALSE;
 hGblFiles = GlobalAlloc(GMEM_ZEROINIT | GMEM_MOVEABLE | GMEM_DDESHARE, \
  sizeof(DROPFILES) + strlen(szFileName) + 2);
 lpData = (LPSTR)GlobalLock(hGblFiles);
 memcpy(lpData, &stDrop, sizeof(DROPFILES));
 strcpy(lpData + sizeof(DROPFILES), szFileName);
 GlobalUnlock(hGblFiles);
 OpenClipboard(NULL);
 EmptyClipboard();
 SetClipboardData(CF_HDROP, hGblFiles);
 SetClipboardData(uDropEffect, hGblEffect);
 CloseClipboard();
 return 1;
}
```


python：

```python
import ctypes
from ctypes import wintypes
import pythoncom
import win32clipboard
class DROPFILES(ctypes.Structure):
    _fields_ = (('pFiles', wintypes.DWORD),
                ('pt',     wintypes.POINT),
                ('fNC',    wintypes.BOOL),
                ('fWide',  wintypes.BOOL))
def clip_files(file_list):
    offset = ctypes.sizeof(DROPFILES)
    length = sum(len(p) + 1 for p in file_list) + 1
    size = offset + length * ctypes.sizeof(ctypes.c_wchar)
    buf = (ctypes.c_char * size)()
    df = DROPFILES.from_buffer(buf)
    df.pFiles, df.fWide = offset, True
    for path in file_list:
        array_t = ctypes.c_wchar * (len(path) + 1)
        path_buf = array_t.from_buffer(buf, offset)
        path_buf.value = path
        offset += ctypes.sizeof(path_buf)
    stg = pythoncom.STGMEDIUM()    
    stg.set(pythoncom.TYMED_HGLOBAL, buf)
    win32clipboard.OpenClipboard()
    try:
        win32clipboard.SetClipboardData(win32clipboard.CF_HDROP,
                                        stg.data)
    finally:
        win32clipboard.CloseClipboard()
if __name__ == '__main__':
    import os
    clip_files([os.path.abspath(__file__)])
```

参考：https://www.codenong.com/37552092/

https://blog.csdn.net/Yoryky/article/details/109118588

python C++ 将文件放入剪切板 之后ctrl+V即可

# 1 借助sublime删除注释





在自己的用户路径下C:\Users\ALG\AppData\Roaming\Sublime Text\Packages\User建立文件remove_comments.py：

```python
import sublime_plugin
import sublime
class RemoveCommentsCommand(sublime_plugin.TextCommand):
    def run(self, edit):
        comments = self.view.find_by_selector('comment')
        for region in reversed(comments):
            self.view.erase(edit, region)
```

![在这里插入图片描述](/static/img/images/00176.png)

这里的默认路径就是刚才的路径：

![在这里插入图片描述](/static/img/images/00177.png)

使用 ctrl+`  打开sublime命令行：

```shell
view.run_command('remove_comments')
```

![在这里插入图片描述](/static/img/images/00178.png)

# 2 其他脚本

修改这里：

config.py

```python
import os
jklp = r"D:\Desktop\AI算法库-吸烟检测算法V1.2"
algname = os.path.basename(jklp)
```

执行这里：

huihui1.py

```python
import os
import re
from config import *
def all_path(dirname):
    result = []
    for maindir, subdir, file_name_list in os.walk(dirname):
        for filename in file_name_list:
            apath = os.path.join(maindir, filename)
            result.append(apath)
    return result
path = jklp
result = []
for name in all_path(path):
    name1 = os.path.join(path, name)
    if name1.endswith(".py"):
        try:
            singleTxt = open(name1, "r", encoding="utf-8").readlines()
            if len(singleTxt) > 10:
                result.extend("\nprint(wqeqweuiqdbkasbd1231241241241241)\n")
                result.append(f"\nprint qqqqqqqqqqqqqqqqqqqqqqqqqqqq {os.path.basename(name)}\n")
                result.extend(singleTxt)
        except:
            pass
open("result.py", "w", encoding='utf-8').writelines(result)
```



使用 sublime删除注释后再使用这里：


huihui2.py

```python
import os
import re
from config import *
Txt = open(r"D:\Desktop\result.py", "r", encoding="utf-8").read()
Txt = Txt.replace("print qqqqqqqqqqqqqqqqqqqqqqqqqqqq", "#")
Txt = Txt.replace("print(wqeqweuiqdbkasbd1231241241241241)", f'"""\nCopyright 2017-2022 ------ Inc \n{algname} \n"""')
open("result1.py", "w", encoding='utf-8').write(Txt)
import os
import re
Txt = open("result1.py", "r", encoding="utf-8").readlines()
Txt = list(filter(lambda x: len(x) > 2, Txt))
# os.remove("result2.py")
open(f"{algname}.py", "w", encoding='utf-8').writelines(Txt)
```

Python 删除python程序的注释

Python





```python
from multiprocessing import Queue, Manager, Process
import time
def process1(queuex: Queue):
    while True:
        queuex.put("dasfdsa")
        time.sleep(1)
def process2(queuex: Queue):
    while True:
        if not queuex.empty():
            path = queuex.get()
            print(path)
if __name__ == '__main__':
    manager = Manager()
    dataq = manager.Queue()
    p1 = Process(target=process1, args=(dataq,))
    p2 = Process(target=process2, args=(dataq,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()
```

Python 多进程通信

![在这里插入图片描述](/static/img/images/00179.png)





安装 
```shell
pip install kafka-python
```

生产者
```python
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='101.112.143.254:59092')
future = producer.send('topic_wx_notice', key=b'my_key', value='my_valuefdsfsdf啊沙发舒服'.encode(), partition=0)
result = future.get(timeout=10)
print(result)
```

消费者

给group_id后，同一个group里面的消费者去消费消息只能消费一次。
```python
from kafka import KafkaConsumer
consumer = KafkaConsumer('topic_wx_notice', bootstrap_servers='101.112.143.254:59092',group_id="weiyiid",
                         value_deserializer=lambda m: m.decode())
for msg in consumer:
    print(msg)
```

python kafka 使用

![在这里插入图片描述](/static/img/images/00180.png)






```python
def get_wind_level_str(wind_speed_float):
    """
    :param wind_speed_float:  风速 m/s
    :return: 风级
    """
    if wind_speed_float < 0.2:
        return 0
    elif wind_speed_float < 1.5:
        return 1
    elif wind_speed_float < 3.3:
        return 2
    elif wind_speed_float < 5.4:
        return 3
    elif wind_speed_float < 7.9:
        return 4
    elif wind_speed_float < 10.7:
        return 5
    elif wind_speed_float < 13.8:
        return 6
    elif wind_speed_float < 17.1:
        return 7
    elif wind_speed_float < 20.7:
        return 8
    elif wind_speed_float < 24.4:
        return 8
    elif wind_speed_float < 28.4:
        return 10
    elif wind_speed_float < 32.6:
        return 11
    elif wind_speed_float < 36.9:
        return 12
    elif wind_speed_float < 41.4:
        return 13
    else:
        return 14
```

风速与风力等级关系 Python

Python





```python
# -*- coding: utf-8 -*-
import datetime
import json
import re
import time
from email.mime.application import MIMEApplication
from email.mime.multipart import MIMEMultipart
from pprint import pprint
import json
import requests
from selenium import webdriver
from selenium.webdriver.support.ui import WebDriverWait
import pandas as pd
import smtplib
from email.mime.text import MIMEText
from email.header import Header
# EmailReceivers = ['kevin.xie@chinaentropy.com']  # 邮件收件人
EmailReceivers = ["xxxx@chinaentropy.com", 'xxxx@chinaentropy.com', "xxxx@chinaentropy.com",
                  "xxxx@chinaentropy.com"]  # 邮件收件人
localFileName = "1234.xlsx"
def send_email_to_d(text, receivers):
    # 第三方 SMTP 服务
    mail_host = "smtp.exmail.qq.com"  # 设置服务器
    mail_user = "xxxx@chinaentropy.com"  # 用户名
    mail_pass = "qqqqqqqqqqq"  # 口令
    sender = 'xxxx@chinaentropy.com'
    message = MIMEMultipart('mixed')  # 邮件内容，mixed为混合形式可传附件
    message['From'] = Header("xxxx@chinaentropy.com", 'utf-8')
    message['To'] = Header(";".join(EmailReceivers), 'utf-8')
    message['Subject'] = Header('和风API调用费用统计', 'utf-8')
    # print(text)  # 邮件文本内容编辑
    text_plain = MIMEText(text, 'plain', 'utf-8')
    message.attach(text_plain)  # 实例化文本
    docxpart = MIMEApplication(open(localFileName, 'rb').read())
    docxpart.add_header('Content-Disposition', 'attachment', filename=localFileName)
    message.attach(docxpart)  # 要发送的exl实例化
    try:
        smtpObj = smtplib.SMTP_SSL(mail_host, 465)
        smtpObj.login(mail_user, mail_pass)
        smtpObj.sendmail(sender, receivers, message.as_string())
        smtpObj.quit()
        print("邮件发送成功")
    except smtplib.SMTPException:
        print("Error: 无法发送邮件")
class scrapyler:
    def __init__(self):
        pass
    def getCookie(self):
        userName = "xxxx"
        userPassword = "xxxxx"
        caps = {
            'browserName': 'chrome',
            'version': '',
            'platform': 'ANY',
            'goog:loggingPrefs': {'performance': 'ALL'},  # 记录性能日志
            'goog:chromeOptions': {'extensions': [], 'args': ['--headless']}  # 无界面模式
        }
        # driver = webdriver.Chrome(executable_path='chromedriver.exe', desired_capabilities=caps)
        driver = webdriver.Chrome(executable_path='/home/pythonPackage/chromedriver', desired_capabilities=caps)
        driver.get('https://id.qweather.com/#/login?redirect=https%3A%2F%2Fconsole.qweather.com%2F#/expenses')
        browser = driver
        print("网页响应中。。。")
        wait = WebDriverWait(browser, 30)
        browser.find_element(by="xpath",
                             value=r"""//*[@id="app"]/div/div/div[2]/div/div[3]/div/div[3]/form/div[1]/div/div/input""").clear()
        browser.find_element(by="xpath",
                             value=r"""//*[@id="app"]/div/div/div[2]/div/div[3]/div/div[3]/form/div[1]/div/div/input""").send_keys(
            userName)
        browser.find_element(by="xpath",
                             value=r"""//*[@id="app"]/div/div/div[2]/div/div[3]/div/div[3]/form/div[2]/div/div/input""").clear()
        browser.find_element(by="xpath",
                             value=r"""//*[@id="app"]/div/div/div[2]/div/div[3]/div/div[3]/form/div[2]/div/div/input""").send_keys(
            userPassword)
        browser.find_element(by="xpath",
                             value=r"""//*[@id="app"]/div/div/div[2]/div/div[3]/div/div[5]/button""").click()
        time.sleep(5)
        balance = float(browser.find_element(by="xpath",
                                             value=r"""//*[@id="page"]/section/main/div/div/div[2]/div[1]/div/div[3]/div[1]/div/span[2]""").text)
        logs = driver.get_log("performance")
        cookies = None
        for i in logs:
            if re.search(r'''"cookie":"[\s\S]{10,200}__HE_CORE__=[\s\S]{10,200}JSESSIONID=[0-9A-Za-z]{10,200}"''',
                         str(i)) is not None:
                cookies = re.search(
                    r'''"cookie":"[\s\S]{10,200}__HE_CORE__=[\s\S]{10,200}JSESSIONID=[0-9A-Za-z]{10,200}"''',
                    str(i)).group()
                break
        assert cookies is not None
        cookie = cookies[10:-1]
        browser.quit()
        # browser.close()
        return cookie, balance
    def getAppBinding(self, cookie):
        prog = requests.get(headers={"cookie": cookie}, url="https://console.qweather.com/v1/rest/app").json()["data"]
        idname = {lt["name"]: lt["id"] for lt in prog}
        print(idname)
        return idname
    def getPurchaseHistory(self, cookie, appId: str,
                           yearmonth: str):  # "https://console.qweather.com/v1/rest/fee/app/95491/type/2?date=2021-11"
        url = f"https://console.qweather.com/v1/rest/fee/app/{appId}/type/2?date={yearmonth}"
        prog = requests.get(headers={"cookie": cookie}, url=url).json()["data"]
        print(prog)
        return prog
    def run(self):
        year = datetime.datetime.now().year - 1 if datetime.datetime.now().month - 1 == 0 else datetime.datetime.now().year
        month = 12 if datetime.datetime.now().month - 1 == 0 else datetime.datetime.now().month - 1
        yearmonthstr = str(year) + "-" + str(month).zfill(2)
        cookie, balance = self.getCookie()
        time.sleep(0.5)
        idname = self.getAppBinding(cookie)
        time.sleep(0.5)
        resultdf = []
        need = ["森林消防", "二块板天气数据库专用", "环保生产"]
        for nd in need:
            prog = self.getPurchaseHistory(cookie, idname[nd], yearmonthstr)
            resultdf.append(pd.DataFrame(prog))
        df = pd.concat(resultdf)
        df["cost"] = df["cost"].apply(float)
        totalMonney = df["cost"].sum()
        df.to_excel(localFileName)
        return totalMonney, need, balance
if __name__ == '__main__':
    # 爬虫获取 总金额，行业名列表，本地文件“和风API调用费用明细.xlsx”
    scrapyler = scrapyler()
    totalMonney, need, balance = scrapyler.run()
    # 发邮件
    if datetime.datetime.now().day == 6 or balance <= 5:
        year = datetime.datetime.now().year - 1 if datetime.datetime.now().month - 1 == 0 else datetime.datetime.now().year
        month = 12 if datetime.datetime.now().month - 1 == 0 else datetime.datetime.now().month - 1
        yearmonthstr = str(year) + "-" + str(month).zfill(2)
        send_email_to_d(f"和风API调用当前余额还剩余  {balance}  元。\n"
                        f"\n"
                        f"\n"
                        f"和风API调用费用统计见附件，{yearmonthstr}月份总消费金额  {totalMonney}   元。\n"
                        f"此统计只包含这些项目行业{str(need)}。\n"
                        f"\n"
                        f"\n"
                        f"--------------------------------------------------------------------------"
                        f"\n"
                        f"此邮件是跑在    http://10.10.90.54:8888/dolphinscheduler/ui/#/resource/file/edit/280     的定时脚本。\n"
                        f"每月6号发一次邮件。每天检测一次余额，余额低于5元也会发本邮件。"
                        f"和风api登录地址: https://id.qweather.com/#/login?redirect=https%3A%2F%2Fconsole.qweather.com%2F#/expenses"
                        f"\n"
                        f"  "
                        ,
                        EmailReceivers)
```

Python selenium smtplib 爬虫获取信息后 发邮件 发附件

Python





```python
from bs4 import BeautifulSoup as bs
html = bs(open("test.html", "r").read(), 'html.parser')
trall = html.find_all(name="tr")
result = []
for tr in trall:
    want = tr.text.strip().replace("\n", " ").split()
    result.append(want)
print(result)
```

Python BeautifulSoup 处理html脚本

raise ValueError("check_hostname requires server_hostname")





ValueError: check_hostname requires server_hostname


关闭VPN即可！