如何在DolphinDB中使用multithreadedTableWriter将数据插入reactiveStateEngine?

问题描述 投票:0回答:1

使用

multithreadedTableWriter
将数据插入到
reactiveStateEngine

示例代码中,可以使用

reactiveStateEngine
直接向
tableInsert
(RSE)插入数据,如:

session.run("tableInsert{reactiveStateEngine}", bar)

但是,我想知道是否可以使用

multithreadedTableWriter
(MTW) 接口将数据写入 RSE。

python api streaming dolphindb
1个回答
0
投票

本质上,引擎也可以通过SQL方式写入数据。引擎的句柄可以认为是一个表对象,API写入操作本质上转换为DolphinDB写入脚本。因此,要向引擎写入数据,只需要将

tableName
设置为引擎句柄即可,即
getStreamEngine('reactiveDemo')

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)
© www.soinside.com 2019 - 2024. All rights reserved.