diff --git a/app/task.py b/app/task.py index bb0dfba..2bc0745 100644 --- a/app/task.py +++ b/app/task.py @@ -50,7 +50,7 @@ def parse_history_message(data): if tmp_content_data_item.get("tag") == "text": message_content_data.append(tmp_content_data_item.get("text")) if tmp_content_data_item.get("tag") == "img": - message_images_data.append({message_id: tmp_content_data_item.get("image_key")}) + message_images_data.append({"message_id": message_id, "image_id": tmp_content_data_item.get("image_key")}) print(message_content_data) @@ -132,9 +132,13 @@ def process_message_callback( record["问题概述"] = "\n".join(message_content_data) - for message_image_message_id, message_image_id in message_images_data.items(): + for message_dict in message_images_data.items(): image_path = get_message_resource( - client, message_image_message_id, message_image_id, "image", cache_dir + client, + message_dict.get("message_id"), + message_dict("image_id"), + "image", + cache_dir, ) print(f"下载文件成功: {image}, {image_path}") file_token = upload_media(client, image_path, "bitable_image", bitable_token)