|
|
@@ -272,34 +272,6 @@ def process_excel(input_excel, output_excel=None):
|
|
|
print(f"处理Excel文件时发生错误: {str(e)}")
|
|
|
raise
|
|
|
|
|
|
-# 读取视频分析报告1.xlsx，找出第10列为空的行，重新调用coze工作流分析
|
|
|
-def process_empty_rows(input_excel, output_excel=None):
|
|
|
- df = pd.read_excel(input_excel)
|
|
|
- for idx, row in df.iterrows():
|
|
|
- if pd.notna(row.iloc[10]):
|
|
|
- continue
|
|
|
- summary = row.iloc[5] if pd.notna(row.iloc[5]) else "{}"
|
|
|
- timeline = row.iloc[7] if pd.notna(row.iloc[7]) else "{}"
|
|
|
- try:
|
|
|
- print(f"开始处理第{idx+1}行")
|
|
|
- resp = call_coze_api(summary, timeline)
|
|
|
- time, query, hook = extract_fields_from_response(resp)
|
|
|
- df.iat[idx, 9] = time # 第8列
|
|
|
- df.iat[idx, 10] = query # 第9列
|
|
|
- df.iat[idx, 11] = hook # 第10列
|
|
|
- print(f"第{idx+1}行处理完成")
|
|
|
- print(hook)
|
|
|
- except Exception as e:
|
|
|
- print(f"第{idx+1}行处理失败: {e}")
|
|
|
- df.iat[idx, 9] = "error"
|
|
|
- df.iat[idx, 10] = "error"
|
|
|
- df.iat[idx, 11] = "error"
|
|
|
- # 每处理一行就保存一次，防止中断丢失
|
|
|
- df.to_excel(input_excel, index=False)
|
|
|
- print(f"已保存到第{idx+1}行")
|
|
|
- df.to_excel(input_excel, index=False)
|
|
|
- print("全部处理完成，已保存。")
|
|
|
-
|
|
|
if __name__ == "__main__":
|
|
|
process_excel("文件/视频分析报告_new.xlsx")
|
|
|
|
