add celery

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))
 
 

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 = []