Echo/fcb-ai-db-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

定时同步数据库功能

Browse Source
This commit is contained in:
liuyebo
2025-01-22 08:58:03 +08:00
parent b6de86bd63
commit c250c6afb9
8 changed files with 549 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
Dockerfile Normal file
View File

@@ -0,0 +1,26 @@
# 使用本地python镜像作为基础镜像
FROM python:3.10.15-bookworm
# 设置工作目录
WORKDIR /home/ucloud
# 设置环境变量
ENV PYTHONUNBUFFERED=1 \
# 设置时区
TZ=Asia/Shanghai \
# 设置pip镜像地址，加快安装速度
PIP_INDEX_URL=https://pypi.tuna.tsinghua.edu.cn/simple
# 安装依赖
COPY requirements.txt /home/ucloud/requirements.txt
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo '$TZ' > /etc/timezone \
&& pip install --no-cache-dir -r requirements.txt
# 将当前目录内容复制到容器的工作目录内
COPY . /home/ucloud
# 暴露端口
# EXPOSE 8081
# 运行python脚本，具体脚本在命令行或docker-compose.yml文件中定义
ENTRYPOINT ["python"]

6
config/config.cfg Normal file
View File

@@ -0,0 +1,6 @@
{
"public_key" : "cqF/0qXI0BS0UyKAlpG/1/4OIpjnFc5orNYj2mW+Rtza5477",
"private_key" : "9b15a6af3d7bdae350b33e844cf306256a2b5fd6",
"proxy_host" : "www.cn-sh2.ufileos.com",
"api_host" : "api.spark.ucloud.cn"
}

4
config/fcb_config.ini Normal file
View File

@@ -0,0 +1,4 @@
[system]
appname=this^andxuhui97.Byp
sysname=xuzhengliang's home
email=jsxuzl@qq.com

19
config/wzx_config3.ini Normal file
View File

@@ -0,0 +1,19 @@
[system]
down_type=2
down_dir=E:\ucloud\uf201906\
down_pdir=E:\ufpaint\pt201906\
file_list=E:\aa2019042.txt
[ucloud]
public_key=P5M5xAAgzounNaZ0eTX+AeFStu4L4cj90WkPQHADCtqOdQAwfYwGHplIrS2a3UJg1Vphn7ftDP/qy3uY3T4ReA==
private_key=eLYcISc9ilYsFJacLuEoNBsdrQEioEt+pr5AkT7BkZTPoi056owjK82yMqQSxqW9mj4W95BM9BS1qOUJaRibTA==
[database]
ssh_address_or_host=gb5NvopZDKWD/NRjwbTyQA==
ssh_username=lFSaYpR/95I6wbJfGg/Ytg==
ssh_password=GoBDJeDRQwaTEK0ogM3DIQ==
remote_bind_address=CkZfcatZvhtJamRY3qMvew==
mysql_user=waxPm9EGm/DO3gogu7c42w==
mysql_password=XkiHYfvVcpm3DkRwC4nX1g==
mysql_database=9VwyHr5HMTMkEdSIPfASHQ==
mysql_port=3306

17
cron.py Normal file
View File

@@ -0,0 +1,17 @@
from datetime import datetime
from time import sleep
import fcbsync_dbphoto_mysql
if __name__ == '__main__':
while 1:
if datetime.now().hour >= 8 and datetime.now().hour < 18:
# 白天间隔10分钟
sleep_time = 10 * 60
else:
# 夜间间隔20分钟
sleep_time = 20 * 60
# 执行同步
fcbsync_dbphoto_mysql.main()
sleep(sleep_time)

9
docker-compose.yml Normal file
View File

@@ -0,0 +1,9 @@
services:
fcb_ai_db_sync:
image: fcb_ai_db_sync:1.0.0
restart: always
build:
context: .
container_name: fcb_ai_db_sync
hostname: fcb_ai_db_sync
command: ["cron.py"]

462
fcbsync_dbphoto_mysql.py Normal file
View File

@@ -0,0 +1,462 @@
"""
功能：将mysql从源数据表同步目标数据表 主要用于ocr 识别及自动脱敏程序
"""
import configparser
#import sys
import os
import platform
import re
import time
# from tkinter import EXCEPTION
import requests
import json
import smtplib
from binascii import a2b_base64, b2a_base64
# import pymssql
import pymysql
import xlrd
# from datetime import datetime, time
from Crypto.Cipher import AES
#from Crypto.PublicKey import RSA
from sshtunnel import SSHTunnelForwarder
from ufile import config, filemanager
from ufile.config import BLOCKSIZE, get_default
from ufile.logger import logger, set_log_file
from email.mime.multipart import MIMEMultipart # 构建邮件头信息，包括发件人，接收人，标题等
from email.mime.text import MIMEText # 构建邮件正文，可以是text，也可以是HTML
from email.mime.application import MIMEApplication # 构建邮件附件，理论上，只要是文件即可，一般是图片，Excel表格，word文件等
from email.header import Header # 专门构建邮件标题的，这样做，可以支持标题中文
#import pysnooper
#import base64
class Prpcrypt(object):
def __init__(self, key):
self.mode = AES.MODE_CBC
self.key = self.pad16(key)
# str不是16的倍数就补足为16的倍数
def pad16(self, text):
text = bytes(text, encoding="utf8")
while len(text) % 16 != 0:
text += b'\0'
return text
def encrypt(self, text):
texts = self.pad16(text)
aes = AES.new(self.key, self.mode, self.key)
res = aes.encrypt(texts)
return str(b2a_base64(res), encoding="utf-8")
def decrypt(self, text):
texts = a2b_base64(self.pad16(text))
aes = AES.new(self.key, self.mode, self.key)
res = str(aes.decrypt(texts), encoding="utf8").replace('\0', '')
return res
# class Logger(object):
# def __init__(self, filename="Default.log"):
# self.terminal = sys.stdout
# self.log = open(filename, "a")
# def write(self, message):
# self.terminal.write(message)
# self.log.write(message)
# def flush(self):
# pass
def send_data(html_msg, v_head, i):
"""发送邮件的脚本"""
# 邮件服务信息，个人
smtp_server = 'smtp.fucb.cn'
username = "xuzhengliang@fucb.cn"
password = 'fu3223x6Zl' # 'fu3223xZl' #
# 邮件发送和接收人yuhong@fucb.cn
sender = username
receiver = ["jsxuzl@qq.com","1515783401@qq.com"]
# receiver = ["xuzhengliang@fucb.cn","jsxuzl@qq.com","1804996986@qq.com"]
# receiver = ['jsxuzl@qq.com']
# v_disdate = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
# 邮件头信息 # 邮件类型，如果要加图片等附件，就得是这个
# if i > 0:
# msg = MIMEMultipart('related')
# content_html = MIMEText(html_msg, "html", "utf-8")
# msg.attach(content_html)
# else:
# # msg = MIMEMultipart('mixed')
msg = MIMEText(html_msg, 'plain', 'utf-8')
if i >= 300:
v_head=v_head+'(处理涂抹状态的案子为'+str(i)+'，请检查ocr 脱敏)'
# msg['Subject'] = Header("{dept}每日提醒,提醒时间{dtype}".format(dept=v_head,dtype=v_disdate,))
msg['Subject'] = Header(v_head, 'utf-8')
msg["From"] = sender
msg['To'] = ','.join(receiver) # 这里要注意
logger.info("{user}发送邮件给{receiver}".format(user=username, receiver=receiver))
logger.info(v_head)
# 发送邮件，测试成功，流程都是固定的：创建客户端，登陆，发送，关闭
email_client = smtplib.SMTP(smtp_server)
email_client.login(username, password)
email_client.sendmail(sender, receiver, msg.as_string())
email_client.quit()
def sync_dbtarget(source_cursor,source_conn,target_cursor,target_db,i_sync_fields,i_query_sql,i_insert_sql,i_table_name,i_sync_begindate,i_imp_table_name):
if i_query_sql.count('%s'):
source_cursor.execute(i_query_sql,(i_sync_begindate))
else:
source_cursor.execute(i_query_sql)
from_data=source_cursor.fetchall()
v_fiels_count=i_sync_fields.count(',')+1
v_fiels_list=i_sync_fields.replace('\n','').replace(' ','').split(',')
# 获取查询结果的长度
rowcount = len(from_data)
v_pk_phhd=''
# 下面语句拼接SQL，实现一次插入1000条，j为行标记
j = 1
sql = ""
for i in from_data:
# v_fields_value=[i[j] for j in v_fiels_list] #有错误
v_fields_value=[i[v_fiels_list[j]] for j in range(0,v_fiels_count)]
# sql2 = '("{}","{}","{}","{}","{}")'.format(i[0], i[1], i[2], i[3], i[4])
if i_table_name=='zx_phhd' or i_table_name=='zx_ie_settlement' or i_table_name=='zx_ie_discharge':
v_pk_phhd = v_pk_phhd+','+str(i['pk_phhd'])
elif i_table_name=='zx_phrec':
if v_pk_phhd=='' or not v_pk_phhd.endswith(','+str(i['pk_phhd'])) :
v_pk_phhd = v_pk_phhd + ',' + str(i['pk_phhd'])
sql2 = (("(" + '"{}",' * v_fiels_count)[:-1] + ")").format(*v_fields_value)
#将 "None"-->null ,"b'\x00'"-->0,"b'\x01'"-->1
#目标表 bit 字段可以不用改为int 字段
sql2 = sql2.replace('"None"',"null")
sql2 = sql2.replace('\"b\'\\x00\'\"',"0")
sql2 = sql2.replace('\"b\'\\x01\'\"',"1")
sql = sql + "," + sql2
if divmod(j, 1000)[1] == 0 or j == rowcount:
# 如果执行错误回滚当前事务
try:
target_cursor.execute(i_insert_sql + sql[1:])
target_db.commit()
except Exception as e:
target_db.rollback()
print('插入失败imp_'+i_table_name+",原因"+str(e))
continue
sql = ""
j = j + 1
# 每一千条打印
if divmod(j, 1000)[1] == 0:
print("已经插入"+i_imp_table_name+":" +str(j) + "条")
print("插入"+i_imp_table_name+":" + str(j - 1) + "条")
if v_pk_phhd[1:] != '':
v_sql ='';
v_mess='';
if i_imp_table_name == 'imp_zx_phrec':
v_sql='update zx_phhd set exreq_times=47 where pk_phhd in (' + v_pk_phhd[1:]+')'
v_mess="更新 zx_phhd exreq_times=47 "
elif i_imp_table_name == 'imp_zx_phhd':
v_sql='update zx_phhd set filetype_id="1" where pk_phhd in (' + v_pk_phhd[1:]+') and exreq_times=47 '
v_mess="更新 zx_phhd filetype_id=1 标志"
elif i_imp_table_name.startswith('imp_zx_phapply'):
v_sql='update zx_phhd set exreq_times=if(cstatus="2",exreq_times+1,108) where pk_phhd in (' + v_pk_phhd[1:]+') '
v_mess="更新 zx_phhd exreq_times=108 "
elif i_imp_table_name.startswith('imp_ie_discharge'):
v_sql='update zx_phhd set exreq_times=exreq_times+1 where pk_phhd in (' + v_pk_phhd[1:]+')'
v_mess="更新 zx_phhd exreq_times=+1 "
elif i_imp_table_name.startswith('imp_ie_settlement'):
v_sql='update zx_phhd set exsuccess_flag="9" where pk_phhd in (' + v_pk_phhd[1:]+') and exreq_times>0 '
v_mess="更新 zx_phhd exsuccess_flag=9 标志"
elif i_imp_table_name.startswith('imp_ie_paint'):
v_sql = 'update zx_phhd set paint_flag="9" where pk_phhd in (' + v_pk_phhd[1:] + ') '
v_mess = "更新 zx_phhd paint_flag=9 标志"
if v_sql !='':
try:
source_cursor.execute(v_sql)
source_conn.commit()
print(v_mess+'成功!'+' from:'+i_table_name+' ,to:'+i_imp_table_name)
except Exception as e:
source_conn.rollback()
print(v_mess+"失败,原因"+str(e))
def main():
# path = os.path.abspath(os.path.dirname(__file__))
#
# sys.stdout = Logger('sync_log.txt')
# 设置请求连接超时时间，单位为秒
config.set_default(connection_timeout=60)
config.set_default(expires=60)
since = time.time()
cfg = configparser.ConfigParser()
os_name = platform.system()
if os_name == "Windows":
cfg.read("D:\\myBaseDoc\\fcb_config.ini")
key = cfg.get("system", "appname")[8:]
cfg.read("D:\\myBaseDoc\\wzx_config3.ini")
elif os_name == "Linux":
cfg.read("/home/ucloud/config/fcb_config.ini")
key = cfg.get("system", "appname")[8:]
cfg.read("/home/ucloud/config/wzx_config3.ini")
#=1 正常图片 =2 涂抹前图片
down_type = cfg.get("system", "down_type")
public_bucket = "pfucb" # 添加公共空间名称
open_file = cfg.get("system", "file_list")
#查看连接是否成功cursor = conn.cursor()
target_conn = pymysql.connect(
user='root',
passwd='test9Root',
host="192.168.5.226",
db='wzxphoto',
port=3308,
cursorclass=pymysql.cursors.DictCursor,
)
# 取数据库连接参数
v_ssh_address_or_host = cfg.get("database", "ssh_address_or_host")
v_ssh_username = cfg.get("database", "ssh_username")
v_ssh_password = cfg.get("database", "ssh_password")
v_remote_bind_address = cfg.get("database", "remote_bind_address")
v_mysql_user = cfg.get("database", "mysql_user")
v_mysql_password = cfg.get("database", "mysql_password")
v_mysql_database = cfg.get("database", "mysql_database")
v_mysql_port = int(cfg.get("database", "mysql_port"))
#解密参数
v_ssh_address_or_host = Prpcrypt(key).decrypt(v_ssh_address_or_host)
#v_ssh_address_or_host = '106.75.249.245'
v_ssh_username = Prpcrypt(key).decrypt(v_ssh_username)
v_ssh_password = Prpcrypt(key).decrypt(v_ssh_password)
v_remote_bind_address = Prpcrypt(key).decrypt(v_remote_bind_address)
v_mysql_user = Prpcrypt(key).decrypt(v_mysql_user)
v_mysql_password = Prpcrypt(key).decrypt(v_mysql_password)
v_mysql_database = Prpcrypt(key).decrypt(v_mysql_database)
# v_mysql_user = "drgphoto"
# v_mysql_password = "PfcB8.67Xl"
# v_mysql_database = "wzx2017"
server = SSHTunnelForwarder(
ssh_address_or_host=(v_ssh_address_or_host, 22), # 指定ssh登录的跳转机的address
ssh_username=v_ssh_username, # 跳转机的用户
ssh_password=v_ssh_password, # 跳转机的密码
remote_bind_address=(v_remote_bind_address, v_mysql_port),
)
server.start()
source_conn = pymysql.connect(
user=v_mysql_user,
passwd=v_mysql_password,
host="127.0.0.1", # 此处必须是是127.0.0.1
# host="10.23.42.171", #此处必须是是127.0.0.1
db=v_mysql_database,
port=server.local_bind_port,
cursorclass=pymysql.cursors.DictCursor,
)
target_cursor = target_conn.cursor()
#清空数据以前先执行
# v_sql="select a.pk_phhd from imp_zx_phapply a left join zx_phhd b on a.pk_phhd=b.pk_phhd where a.cStatus='3' and b.pk_phhd is null"
v_sql ='''
SELECT a.pk_phhd
FROM imp_zx_phapply a LEFT JOIN zx_phhd b ON a.pk_phhd = b.pk_phhd
WHERE b.pk_phhd IS NULL
UNION ALL
SELECT a.pk_phhd
FROM imp_zx_phapply a INNER JOIN zx_phhd b ON a.pk_phhd = b.pk_phhd
WHERE a.billdate > b.billdate;
'''
# a.cStatus = '3' AND a.cStatus = '2' AND
target_cursor.execute(v_sql)
from_data = target_cursor.fetchall()
c_pk_phhdlist = ','.join(str(rec['pk_phhd']) for rec in from_data)
c_nopk_phhd=''
if target_cursor.rowcount>0:
c_nopk_phhd=" or (h.pk_phhd in ("+c_pk_phhdlist+")) "
try:
v_sql='select imp_table_name from sys_sync_tables where sync_direct="1" and exp_table_delfalg="1" AND imp_table_name<>exp_table_name ;'
target_cursor.execute(v_sql)
from_data = target_cursor.fetchall()
if len(from_data) >0:
for rec in from_data:
if rec['imp_table_name'].startswith('imp_'):
v_sql ='delete from '+ rec['imp_table_name']+';'
target_cursor.execute(v_sql)
target_conn.commit
except Exception as e:
target_conn.rollback()
print("删除目标表失败"+"imp_开头表,原因"+str(e))
source_cursor = source_conn.cursor()
try:
v_sql='select imp_table_name from sys_sync_tables where sync_direct="2" and exp_table_delfalg="1" AND imp_table_name<>exp_table_name ;'
target_cursor.execute(v_sql)
from_data = target_cursor.fetchall()
if len(from_data) >0:
for rec in from_data:
if rec['imp_table_name'].startswith('imp_'):
v_sql ='delete from '+ rec['imp_table_name']+';'
source_cursor.execute(v_sql)
source_conn.commit
except Exception as e:
source_conn.rollback()
print("删除源表失败"+"imp_开头表,原因"+str(e))
#v_sql ="select date_format(date_sub(max(sync_date),interval 1 day) , '%Y-%m-%d') pk_maxvalue from wzx2017.sys_sybnc_date"
v_sql ="select date_format(ifnull(max(sync_date),CURRENT_DATE), '%Y-%m-%d') pk_maxvalue from sys_sync_date "
target_cursor.execute(v_sql)
results = target_cursor.fetchone()
v_sync_begindate = results['pk_maxvalue']
# v_sync_begindate ='2022-04-01'
v_sql = 'select * from sys_sync_tables where sync_direct="1" and del_flag=0 order by 1 '
target_cursor.execute(v_sql)
from_data = target_cursor.fetchall()
for rec in from_data:
v_exp_table_name = rec['exp_table_name']
v_imp_table_name = rec['imp_table_name']
v_imp_table_maxsql = rec['imp_table_maxsql']
v_fields = rec['sync_fields'].replace('\r', '').replace('\n', '').replace(' ', '')
v_query_table = rec['query_table'].replace('#fields', v_fields).replace('#exp_table_name',v_exp_table_name)
v_insert_table = rec['insert_table'].replace('#fields',v_fields).replace('#imp_table_name',v_imp_table_name)
if v_imp_table_name=='imp_zx_phrec' or v_imp_table_name=='imp_zx_phhd':
v_query_table=v_query_table.replace('#nopk_phlist',c_nopk_phhd)
# print(v_imp_table_maxsql)
if v_imp_table_maxsql != '-':
v_sql=v_imp_table_maxsql.replace('#dbname',db_name).replace('#imp_table_name',v_exp_table_name)
target_cursor.execute(v_sql)
results = target_cursor.fetchone()
v_pk_maxvalue = results['pk_maxvalue']
v_query_table =v_query_table.replace('#pk_maxvalue',str(v_pk_maxvalue))
sync_dbtarget(source_cursor,source_conn,target_cursor,target_conn,v_fields,v_query_table,v_insert_table,v_exp_table_name,v_sync_begindate,v_imp_table_name)
time_elapsed = time.time() - since
v_title = "花费{mtime:.0f}分{stime:.0f}秒时间,同步成功!".format(
mtime=time_elapsed // 60,
stime=time_elapsed % 60)
print(v_title)
v_sql = 'insert into sys_sync_date(sync_date,sync_direct,depiction) values(CURRENT_TIMESTAMP,"1","{}") '.format(v_title)
try:
target_cursor.execute(v_sql)
target_conn.commit()
except Exception as e:
print('追加记录至sys_sybnc_date失败？' + ",原因" + str(e))
target_conn.rollback()
v_sql = 'call pro_sync_waitfor_ocrdata(1,@dd);'
try:
target_cursor.execute(v_sql)
target_conn.commit()
except Exception as e:
print('同步至待ocr 识别完成失败(pro_sync_waitfor_ocrdata)？' + ",原因" + str(e))
target_conn.rollback()
v_sql = 'select * from sys_sync_tables where sync_direct="2" and del_flag=0 order by 1 '
target_cursor.execute(v_sql)
from_data = target_cursor.fetchall()
for rec in from_data:
v_exp_table_name = rec['exp_table_name']
v_imp_table_name = rec['imp_table_name']
v_imp_table_maxsql = rec['imp_table_maxsql']
v_fields = rec['sync_fields'].replace('\r', '').replace('\n', '').replace(' ', '')
v_query_table = rec['query_table'].replace('#fields', v_fields).replace('#exp_table_name', v_exp_table_name)
v_insert_table = rec['insert_table'].replace('#fields', v_fields).replace('#imp_table_name', v_imp_table_name)
# print(v_imp_table_maxsql)
if v_imp_table_maxsql != '-':
v_sql = v_imp_table_maxsql.replace('#dbname', db_name).replace('#imp_table_name', v_exp_table_name)
target_cursor.execute(v_sql)
results = target_cursor.fetchone()
v_pk_maxvalue = results['pk_maxvalue']
v_query_table = v_query_table.replace('#pk_maxvalue', str(v_pk_maxvalue))
sync_dbtarget(target_cursor, target_conn,source_cursor, source_conn, v_fields, v_query_table, v_insert_table,
v_exp_table_name, v_sync_begindate,v_imp_table_name)
time_elapsed = time.time() - since
v_title = "花费{mtime:.0f}分{stime:.0f}秒时间,同步成功!".format(
mtime=time_elapsed // 60,
stime=time_elapsed % 60)
print(v_title)
v_sql = 'insert into sys_sync_date(sync_date,sync_direct,depiction) values(CURRENT_TIMESTAMP,"2","{}") '.format(v_title)
try:
target_cursor.execute(v_sql)
target_conn.commit()
except Exception as e:
print('追加记录至sys_sybnc_date失败？' + ",原因" + str(e))
target_conn.rollback()
v_sql = 'call pro_photoocr_update(1,@dd);'
try:
source_cursor.execute(v_sql)
source_conn.commit()
except Exception as e:
print('ocr识别结果同步完成失败(pro_photoocr_update)？' + ",原因" + str(e))
source_conn.rollback()
v_sql = "select a.pk_phhd from imp_zx_phapply a left join zx_phhd b on a.pk_phhd=b.pk_phhd where a.cStatus='2' and b.pk_phhd is null;"
target_cursor.execute(v_sql)
reccount = target_cursor.rowcount
from_data = target_cursor.fetchall()
v_pk_phhd = ''
v_error=''
if reccount > 0:
for row_num, row in enumerate(from_data):
v_pk_phhd = v_pk_phhd + ',' + str(row['pk_phhd'])
v_sql = "update zx_phhd set filetype_id='0' where pk_phhd in ("+v_pk_phhd[1:]+") and cStatus='2' and filetype_id='1'; "
try:
source_cursor.execute(v_sql)
source_conn.commit()
except Exception as e:
v_error='(存在待ocr识别但没有成功的案子，自动处理失败' + ",原因" + str(e)+')'
print(v_error)
source_conn.rollback()
v_sql = "select count(1) jl from zx_phhd where paint_flag in ('1','2');"
target_cursor.execute(v_sql)
from_data = target_cursor.fetchone()
v_paint=from_data['jl']
v_sql = "select count(1) jl from imp_zx_phapply a left join zx_phhd b on a.pk_phhd=b.pk_phhd where a.cStatus='3' and b.pk_phhd is null;"
target_cursor.execute(v_sql)
from_data = target_cursor.fetchone()
v_paintno = from_data['jl']
v_defpaintno=''
if v_paintno>0:
v_defpaintno="(存在需要脱敏但不存在的案子{fnum}个)".format(fnum=v_paintno)
#关闭数据库连接
source_conn.close()
target_conn.close()
server.close()
html_msg = ' '
v_disdate = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
v_head = '{cerror}{nopaint}案子待ocr识别同步至数据库成功,ocr识别结果反馈成功,花费{mtime:.0f}分{stime:.0f}秒时间,结束时间{dtype}!'.format(mtime=time_elapsed // 60,
stime=time_elapsed % 60,
dtype=v_disdate,
cerror=v_error,
nopaint=v_defpaintno,
)
# v_head=v_mess+v_head
## 定义上午11点和中午12点的时间对象
v_hour=time.strftime("%H", time.localtime(time.time()))
if ('09'<=v_hour<'10' or '17'<=v_hour<'18') or v_paint>300 :
send_data(html_msg, v_head,v_paint)
# os._exit(0)

6
requirements.txt Normal file
View File

@@ -0,0 +1,6 @@
pycryptodome==3.21.0
pymysql==1.1.1
requests==2.32.3
sshtunnel==0.4.0
ufile==3.2.9
xlrd==2.0.1