|
|
@@ -2,7 +2,7 @@ import time
|
|
|
from funboost import boost, BrokerEnum, run_forever, funboost_aps_scheduler
|
|
|
from Ansjer.config import LOGGER
|
|
|
from Model.models import Device_Info
|
|
|
-
|
|
|
+import sys
|
|
|
|
|
|
@boost("task_queue_name1", qps=0.5, broker_kind=BrokerEnum.REDIS_ACK_ABLE) # 入参包括20种，运行控制方式非常多，想得到的控制都会有。
|
|
|
def task_fun(x, y):
|
|
|
@@ -16,6 +16,7 @@ if __name__ == "__main__":
|
|
|
# for i in range(2):
|
|
|
# task_fun.pub(dict(x=i, y=i * 2))
|
|
|
# task_fun.push(i, y=i * 2) # 发布者发布任务
|
|
|
+ print(sys.path)
|
|
|
funboost_aps_scheduler.add_push_job(task_fun, 'cron', day_of_week='*', hour=9, minute=30, second=00,
|
|
|
kwargs={"x": 5, "y": 6}) # 每隔3秒发布一次任务，自然就能每隔3秒消费一次任务了。
|
|
|
funboost_aps_scheduler.start()
|
Ansjer