1

ai_pyppeteer.py

@@ -450,22 +450,26 @@ class ToWork:
 
 
 def process_start(browser_item, lock):
-    loop = asyncio.get_event_loop()
-    keyword = ToWork(browser_item, lock)
-    logger.info('开始执行任务')
-    # 生产
-    loop.run_until_complete(keyword.on_start())
-
-    # 测试
-    # task = {
-    #     'policy': 'http://test.phpgpt.com/api/users/config/policy2'
-    # }
-    # href = 'https://cdn.discordapp.com/attachments/1090583268467945475/1093734564188409946/suifeng_a_very_cute_boys_16_years_old_fly_a_kitein_beautifulstr_cd2d65d6-ea40-432b-9941-c796504b6082.png'
-    # loop.run_until_complete(keyword.upload_img(task, href))
+    try:
+        logger.info('开始执行任务')
+        loop = asyncio.get_event_loop()
+        keyword = ToWork(browser_item, lock)
+        logger.info('开始执行任务2')
+        # 生产
+        loop.run_until_complete(keyword.on_start())
+        # 测试
+        # task = {
+        #     'policy': 'http://test.phpgpt.com/api/users/config/policy2'
+        # }
+        # href = 'https://cdn.discordapp.com/attachments/1090583268467945475/1093734564188409946/suifeng_a_very_cute_boys_16_years_old_fly_a_kitein_beautifulstr_cd2d65d6-ea40-432b-9941-c796504b6082.png'
+        # loop.run_until_complete(keyword.upload_img(task, href))
+    except Exception as e:
+        logger.error(e)
 
 
 if __name__ == '__main__':
     try:
+        logger.info('__main__')
         browser_list = [
             {
                 'num': 2,
@@ -475,6 +479,7 @@ if __name__ == '__main__':
         lock = Lock()
         l = []
         for item in browser_list:
+            logger.info('任务进程')
             p = Process(target=process_start, args=(item, lock))
             p.start()
             l.append(p)  # 将进程加入列表中，这样 5 个子进程就会全部执行

gpt.py

 import asyncio
 import json
+import multiprocessing
 import time
 import requests
 
@@ -89,6 +90,7 @@ def get_gpt_message(task):
 
 
 if __name__ == '__main__':
+    multiprocessing.freeze_support()
     key = 'laravel_database_gpt_text_prompt'
     logger.info('开始执行')
     while True: