VeighNa量化社区
你的开源社区量化交易平台
rhett-butler's Avatar
Member
离线
1 帖子
声望: 0

def move_df_to_mongodb(imported_data:pd.DataFrame,collection_name:str):
from datetime import datetime, timedelta, timezone
bars = []
start = None
count = 0
utc_8 = timezone(timedelta(hours=8))
for row in imported_data.itertuples():
bar = BarData(

          symbol=row.symbol,
          exchange=row.exchange,
          datetime=row.datetime.replace(tzinfo=utc_8),
          interval=row.interval,
          volume=row.volume,
          open_price=row.open,
          high_price=row.high,
          low_price=row.low,
          close_price=row.close,
          open_interest=row.open_interest,
          gateway_name="DB",

    )


    bars.append(bar)

    # do some statistics
    count += 1
    if not start:
        start = bar.datetime
end = bar.datetime

# insert into database
database_manager.save_bar_data(bars)
print(r"Insert Bar: {count} from {start} - {end}")

move_df_to_mongodb(imported_data,'cu1603')

报错
TypeError Traceback (most recent call last)

<ipython-input-27-1aae6c50af37> in <module>
----> 1 move_df_to_mongodb(imported_data,'cu1603')

<ipython-input-26-12b650cfca76> in move_df_to_mongodb(imported_data, collection_name)
10 symbol=row.symbol,
11 exchange=row.exchange,
---> 12 datetime=row.datetime.replace(tzinfo=utc_8),
13 interval=row.interval,
14 volume=row.volume,

TypeError: replace() takes no keyword arguments

数据插入就一直报错,请问下这个该怎么处理?

© 2015-2022 微信 18391752892
备案服务号:沪ICP备18006526号

沪公网安备 31011502017034号

【用户协议】
【隐私政策】
【免责条款】