调试

common/feishu.py

@@ -44,7 +44,7 @@ class Feishu:
             tenant_access_token = response.json()["tenant_access_token"]
             return tenant_access_token
         except Exception as e:
-            Common.logger().error("获取飞书 api token 异常:{}", e)
+            Common.logger("feishu").error("获取飞书 api token 异常:{}", e)
 
     # 获取表格元数据
     @classmethod
@@ -70,7 +70,7 @@ class Feishu:
             response = json.loads(r.content.decode("utf8"))
             return response
         except Exception as e:
-            Common.logger().error("获取表格元数据异常:{}", e)
+            Common.logger("feishu").error("获取表格元数据异常:{}", e)
 
     # 读取工作表中所有数据
     @classmethod
@@ -112,7 +112,7 @@ class Feishu:
             values = response["data"]["valueRanges"][0]["values"]
             return values
         except Exception as e:
-            Common.logger().error("读取工作表所有数据异常:{}", e)
+            Common.logger("feishu").error("读取工作表所有数据异常:{}", e)
 
     # 工作表，插入行或列
     @classmethod
@@ -145,9 +145,9 @@ class Feishu:
 
             urllib3.disable_warnings()
             r = requests.post(url=insert_columns_url, headers=headers, json=body, proxies=proxies, verify=False)
-            Common.logger().info("插入行或列:{}", r.json()["msg"])
+            Common.logger("feishu").info("插入行或列:{}", r.json()["msg"])
         except Exception as e:
-            Common.logger().error("插入行或列异常:{}", e)
+            Common.logger("feishu").error("插入行或列异常:{}", e)
 
     # 写入数据
     @classmethod
@@ -177,9 +177,9 @@ class Feishu:
             }
             urllib3.disable_warnings()
             r = requests.post(url=update_values_url, headers=headers, json=body, proxies=proxies, verify=False)
-            Common.logger().info("写入数据:{}", r.json()["msg"])
+            Common.logger("feishu").info("写入数据:{}", r.json()["msg"])
         except Exception as e:
-            Common.logger().error("写入数据异常:{}", e)
+            Common.logger("feishu").error("写入数据异常:{}", e)
 
     # 合并单元格
     @classmethod
@@ -205,9 +205,9 @@ class Feishu:
             }
             urllib3.disable_warnings()
             r = requests.post(url=merge_cells_url, headers=headers, json=body, proxies=proxies, verify=False)
-            Common.logger().info("合并单元格:{}", r.json()["msg"])
+            Common.logger("feishu").info("合并单元格:{}", r.json()["msg"])
         except Exception as e:
-            Common.logger().error("合并单元格异常:{}", e)
+            Common.logger("feishu").error("合并单元格异常:{}", e)
 
     # 读取单元格数据
     @classmethod
@@ -241,7 +241,7 @@ class Feishu:
             # print(r.text)
             return r.json()["data"]["valueRange"]["values"][0]
         except Exception as e:
-            Common.logger().error("读取单元格数据异常:{}", e)
+            Common.logger("feishu").error("读取单元格数据异常:{}", e)
     # 获取表内容
     @classmethod
     def get_sheet_content(cls, log_type, crawler, sheet_id):
@@ -256,7 +256,7 @@ class Feishu:
                         content_list.append(y)
             return content_list
         except Exception as e:
-            Common.logger().error(f'get_sheet_content:{e}\n')
+            Common.logger("feishu").error(f'get_sheet_content:{e}\n')
 
     # 删除行或列，可选 ROWS、COLUMNS
     @classmethod
@@ -288,9 +288,9 @@ class Feishu:
             }
             urllib3.disable_warnings()
             r = requests.delete(url=dimension_range_url, headers=headers, json=body, proxies=proxies, verify=False)
-            Common.logger().info("删除视频数据:{}", r.json()["msg"])
+            Common.logger("feishu").info("删除视频数据:{}", r.json()["msg"])
         except Exception as e:
-            Common.logger().error("删除视频数据异常:{}", e)
+            Common.logger("feishu").error("删除视频数据异常:{}", e)
 
     # 获取用户 ID
     @classmethod
@@ -319,7 +319,7 @@ class Feishu:
 
             return open_id
         except Exception as e:
-            Common.logger().error(f"get_userid异常:{e}\n")
+            Common.logger("feishu").error(f"get_userid异常:{e}\n")
 
     # 飞书机器人
     @classmethod
@@ -385,9 +385,9 @@ class Feishu:
             })
             urllib3.disable_warnings()
             r = requests.post(url, headers=headers, data=data, verify=False, proxies=proxies)
-            Common.logger().info(f'触发机器人消息:{r.status_code}, {text}')
+            Common.logger("feishu").info(f'触发机器人消息:{r.status_code}, {text}')
         except Exception as e:
-            Common.logger().error(f"bot异常:{e}\n")
+            Common.logger("feishu").error(f"bot异常:{e}\n")
 
 
 if __name__ == "__main__":

common/scheduling_db.py

@@ -78,7 +78,7 @@ class MysqlHelper:
             # 返回查询结果，元组
             return data
         except Exception as e:
-            Common.logger(log_type, crawler).error(f"get_values异常:{e}\n")
+            Common.logger(log_type).error(f"get_values异常:{e}\n")
 
     @classmethod
     def update_values(cls, log_type, crawler, sql, env, action=''):
@@ -94,7 +94,7 @@ class MysqlHelper:
             connect.commit()
             return res
         except Exception as e:
-            Common.logger(log_type, crawler).error(f"update_values异常，进行回滚操作:{e}\n")
+            Common.logger(log_type).error(f"update_values异常，进行回滚操作:{e}\n")
             # 发生错误时回滚
             connect.rollback()