4.69K 浏览
0

D:\Python38\lib\site-packages\tqsdk\api.py:1160: DeprecationWarning: Task.current_task() is deprecated, use asyncio.current_task() instead
if asyncio.Task.current_task(loop=self._loop) is None:

经常反复出现以上提示,但好像也不影响开仓、平仓等。

不知有没有什么影响?如果没有什么不良影响,能否屏蔽这种提示?

ringo 已回答的问题 2020年9月4日
0

能有最小复现代码发我们看看么

tygk98 发表新评论 2020年9月4日

class WorkerThread(threading.Thread):
def __init__(self, api, symbol):
threading.Thread.__init__(self)
self.api = api
self.symbol = symbol

def run(self):
SHORT = 30 # 短周期
LONG = 60 # 长周期
data_length = LONG + 2 # k线数据长度
klines = self.api.get_kline_serial(self.symbol, duration_seconds=60, data_length=data_length)
target_pos = TargetPosTask(self.api, self.symbol)

while True:
self.api.wait_update()
if self.api.is_changing(klines.iloc[-1], “datetime”): # 产生新k线:重新计算SMA
short_avg = ma(klines[“close”], SHORT) # 短周期
long_avg = ma(klines[“close”], LONG) # 长周期
if long_avg.iloc[-2] short_avg.iloc[-1]:
target_pos.set_target_volume(-3)
print(“均线下穿,做空”)
if short_avg.iloc[-2] long_avg.iloc[-1]:
target_pos.set_target_volume(3)
print(“均线上穿,做多”)

if __name__ == “__main__”:
api_master = TqApi(TqSim())

# Create new threads
thread1 = WorkerThread(api_master.copy(), “SHFE.cu1901”)
thread2 = WorkerThread(api_master.copy(), “SHFE.rb1901”)

# Start new Threads
thread1.start()
thread2.start()

while True:
api_master.wait_update()

您正在查看3个答案中的1个,单击此处查看所有答案。