请问如何通过multithreadedTableWriter向reactiveStateEngine里面insert数据?

如题。


我看到示例代码中可以通过tableInsert直接往rse里面insert数据,如session.run(""" tableInsert{reactiveStateEngine}""", bar)。那么能否使用mtw呢?

请先 登录 后评论

1 个回答

Polly

可以这样写:   

writer = ddb.MultithreadedTableWriter(host="183.134.101.143", port=8911, userId="admin", password="DolphinDB@123", dbPath="",
                                     tableName ="getStreamEngine('reactiveDemo')", useSSL=False, enableHighAvailability=False, highAvailabilitySites=[],
                                     batchSize=10000, throttle=1, threadCount=1)
请先 登录 后评论
  • 1 关注
  • 0 收藏,158 浏览
  • 提出于 2024-04-17 10:42

相似问题