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
数据插入就一直报错,请问下这个该怎么处理?