所以我尝试了很多不同的方法,但我无法回避。基本上是这样的:
api函数调用返回列表中的dict。
我有一个参数列表,需要逐个传递给上面的函数。
我不在乎秩序。
最后一步是将该列表附加到pandas.dataframe,它将删除重复项和顺序等。示例(顺便说一句,api是python二进制):
symbols = ['ADAUSDT', 'ETHUSDT', 'BTCUSDT']
orders = pd.DataFrame()
for s in symbols:
orders = orders.append(client.get_all_orders(symbol=s)) # This returns the Dict
我尝试使用queue()和thread(),两者都使用lock()。我也尝试了threadpoolexecutor(),但无法使其工作。我所能达到的最大值是最后一个方法,但每次执行后不同的行数:
orders = pd.DataFrame()
temp = []
with ThreadPoolExecutor() as executor:
executor.map(get_orders, symbols)
for x in temp:
orders = orders.append([x])
有什么想法吗?
谢谢
暂无答案!
目前还没有任何答案,快来回答吧!