diff --git a/app/__init__.py b/app/__init__.py index a2a9b7a..35a6da7 100644 --- a/app/__init__.py +++ b/app/__init__.py @@ -48,8 +48,10 @@ if not os.path.exists(cache_dir): def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None: - print(client, bitable_token, table_id, cache_dir, data) - process_message_callback.delay(client, bitable_token, table_id, cache_dir, data) + # print(client, bitable_token, table_id, cache_dir, data) + process_message_callback.delay( + app_id, app_secret, bitable_token, table_id, cache_dir, data + ) print(lark.JSON.marshal(data)) diff --git a/app/task.py b/app/task.py index 1b6249c..af3d180 100644 --- a/app/task.py +++ b/app/task.py @@ -29,7 +29,11 @@ def process(self: Task, total: int) -> object: @shared_task(include_result=False) -def process_message_callback(client, bitable_token, table_id, cache_dir, data) -> None: +def process_message_callback( + app_id, app_secret, bitable_token, table_id, cache_dir, data +) -> None: + client = lark.Client.builder().app_id(app_id).app_secret(app_secret).build() + record = {} images = [] images_token = []