code: def track_strategy_worker(self, strategy, name, interval=10, **kwargs):
          
          while True:
              try:
                  transactions = self.query_strategy_transaction(
                      strategy, **kwargs
                  )
              # pylint: disable=broad-except
              except Exception as e:
                  log.exception("无法获取策略 %s 调仓信息, 错误: %s, 跳过此次调仓查询", name, e)
                  time.sleep(3)
                  continue
              for transaction in transactions:
                  trade_cmd = {
                      "strategy": strategy,
                      "strategy_name": name,
                      "action": transaction["action"],
                      "stock_code": transaction["stock_code"],
                      "amount": transaction["amount"],
                      "price": transaction["price"],
                      "datetime": transaction["datetime"],
                  }
                  if self.is_cmd_expired(trade_cmd):
                      continue
                  log.info(
                      "策略 [%s] 发送指令到交易队列, 股票: %s 动作: %s 数量: %s 价格: %s 信号产生时间: %s",
                      name,
                      trade_cmd["stock_code"],
                      trade_cmd["action"],
                      trade_cmd["amount"],
                      trade_cmd["price"],
                      trade_cmd["datetime"],
                  )
                  self.trade_queue.put(trade_cmd)
                  self.add_cmd_to_expired_cmds(trade_cmd)
              try:
                  for _ in range(interval):
                      time.sleep(1)
              except KeyboardInterrupt:
                  log.info("程序退出")
                  break
docs: 跟踪下单worker
          :param strategy: 策略id
          :param name: 策略名字
          :param interval: 轮询策略的时间间隔，单位为秒