automation_provide_job_repair.py 1.1 KB

123456789101112131415161718192021222324252627282930
  1. import json
  2. from client.AIGCClient import AIGCClient
  3. aigc_client = AIGCClient(token="8bf14f27fc3a486788f3383452422d72", base_url="https://aigc-api.aiddit.com")
  4. log_list = []
  5. with open("/Users/zhao/Downloads/1680aba3-fa5b-4d53-8386-22cb1c3c8472.json", 'r') as f:
  6. line = f.readline()
  7. while line:
  8. log_list.append(json.loads(line))
  9. line = f.readline()
  10. for log in log_list:
  11. crawler_plan_id = log.get("crawlerPlanId")
  12. video_id = log.get("videoId")
  13. input_mode_values = log.get('inputModeValues')
  14. error_msg, crawler_plan_info = aigc_client.get_content_crawler_plan_by_id(crawler_plan_id)
  15. if error_msg:
  16. print(f"获取 {crawler_plan_id} 的爬取信息异常")
  17. continue
  18. update_use_date = crawler_plan_info.get("updateData")
  19. crawler_plan_name = update_use_date['name']
  20. if "{话题}" not in crawler_plan_name:
  21. continue
  22. new_crawler_plan_name = crawler_plan_name.replace("{话题}", input_mode_values)
  23. update_use_date['name'] = new_crawler_plan_name
  24. aigc_client.crawler_plan_save(update_use_date)