python ddb.PartitionedTableAppender.append 写入数据,数据串行

基于vnpy_dolphindb修改的脚本,将pandas.DataFrame写入到数据库的时候,数据库串行

attachments-2023-09-9eVIFUzY65122dbeed58d.png

下图是写入的df.head()[['symbol', 'exchange']]

attachments-2023-09-oqB6ZAMa65121cb398434.png


原本的symbol数据被存到数据库的exchange字段里

原本的exchange字段被存到数据库的symbol字段里

attachments-2023-09-jgyeVLf465122efeb6cb4.png

请教一下,可能是哪里出问题呢?

请先 登录 后评论

最佳答案 2023-09-26 18:29

df.head()[['symbol', 'exchange']] 会按照 symbol, exchange 的顺序去打印,而不一定是原 df 的顺序去打印。

如果顺利入库且字段能对应上,说明 df 写入的字段数据和分布式表的表结构顺序的一致的,即原本 df 的顺序是按照 symbol exchange,应该是没问题的。

请先 登录 后评论

其它 0 个回答

  • 1 关注
  • 0 收藏,491 浏览
  • tianmingzhizi 提出于 2023-09-26 07:59

相似问题