修改数据库

common/db.py

@@ -13,10 +13,11 @@ class MysqlHelper:
     def connect_mysql(cls):
         # 创建一个 Connection 对象，代表了一个数据库连接
         connection = pymysql.connect(
-            host="rm-bp1k5853td1r25g3n690.mysql.rds.aliyuncs.com",# 数据库IP地址，内网地址
+            # host="rm-bp1k5853td1r25g3n690.mysql.rds.aliyuncs.com",# 数据库IP地址，内网地址
+            host="rr-bp1l12ea7e9wgu947.mysql.rds.aliyuncs.com",
             # host="rm-j6cz4c6pt96000xi3lo.mysql.rds.aliyuncs.com",# 数据库IP地址，外网地址
             port=3306,                      # 端口号
-            user="wx2016_longvideo",                 #  mysql用户名
+            user="longvideo_read",                 #  mysql用户名
             passwd="wx2016_longvideoP@assword1234",        # mysql用户登录密码
             db="longvideo",         # 数据库名
             # 如果数据库里面的文本是utf8编码的，charset指定是utf8

single_video/get_vx_message.py

@@ -10,7 +10,7 @@ from datetime import datetime
 
 
 sys.path.append(os.getcwd())
-from common import MysqlHelper, Feishu
+from common import MysqlHelper, Feishu, Common
 from single_video.gongzhonghao.gongzhonghao_video import  gongzhonghaoVdieo
 from single_video.shipinhao.shipinhao_author import shipinhaoVdieo
 from single_video.douyin.douyin_video import douyinVideo
@@ -40,6 +40,7 @@ class VxMessage():
         id = cls.read_id()
         vx_list = cls.get_vx_message(id)
         if vx_list:
+            Common.logger().info(f"查询到数据{vx_list}")
             for vx_message in vx_list:
                 msg_type = vx_message[0]
                 content = vx_message[1]
@@ -87,8 +88,7 @@ class VxMessage():
                 time.sleep(0.5)
                 Feishu.update_values('video', "edd0a8", "A2:Z2", values)
         else:
-            print("没数据哦")
-
+            Common.logger().info("数据库没有查询到数据")
 
 
 if __name__ == '__main__':