浏览代码

funboost测试代码

peng 2 年之前
父节点
当前提交
f8e0072804
共有 1 个文件被更改,包括 2 次插入0 次删除
  1. 2 0
      Object/FunboostFrameWork/funboost_task.py

+ 2 - 0
Object/FunboostFrameWork/funboost_task.py

@@ -1,6 +1,8 @@
 import time
 import time
 from funboost import boost, BrokerEnum, run_forever, funboost_aps_scheduler
 from funboost import boost, BrokerEnum, run_forever, funboost_aps_scheduler
 from Ansjer.config import LOGGER
 from Ansjer.config import LOGGER
+from Model.models import Device_Info
+
 
 
 @boost("task_queue_name1", qps=0.5, broker_kind=BrokerEnum.REDIS_ACK_ABLE)  # 入参包括20种,运行控制方式非常多,想得到的控制都会有。
 @boost("task_queue_name1", qps=0.5, broker_kind=BrokerEnum.REDIS_ACK_ABLE)  # 入参包括20种,运行控制方式非常多,想得到的控制都会有。
 def task_fun(x, y):
 def task_fun(x, y):