funboost代码测试

Ansjer/local_config/local_settings.py

@@ -79,7 +79,7 @@ WSGI_APPLICATION = 'Ansjer.local_config.local_wsgi.application'
 DATABASE_DATA = 'ansjer'
 SERVER_HOST = '127.0.0.1'
 DATABASES_USER = 'root'
-DATABASES_PASS = '0000'
+DATABASES_PASS = '123456'
 
 # 推送数据库
 DATABASE_DATA2 = 'push'

Controller/TestApi.py

@@ -37,7 +37,7 @@ from Object.TokenObject import TokenObject
 from Object.m3u8generate import PlaylistGenerator
 from Service.CommonService import CommonService
 from Service.VodHlsService import SplitVodHlsObject
-from funboost import boost, BrokerEnum
+from funboost import boost, BrokerEnum, funboost_aps_scheduler
 
 ACCESS_KEY = "AKIA2E67UIMD3CYTIWPA"
 SECRET_KEY = "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"
@@ -913,6 +913,9 @@ class testView(View):
 
 
     def funboost_test(self, request_dict, response):
-        self.task_fun.push(x=5, y=6)
+        # self.task_fun.push(x=5, y=6)
+        funboost_aps_scheduler.start()
+        funboost_aps_scheduler.add_push_job(self.task_fun, 'interval', id='3_second_job', seconds=60,
+                                            kwargs={"x": 5, "y": 6})  # 每隔3秒发布一次任务，自然就能每隔3秒消费一次任务了。
         self.task_fun.consume()
         return response.json(0)