使用
multithreadedTableWriter
将数据插入到 reactiveStateEngine
示例代码中,可以使用
reactiveStateEngine
直接向tableInsert
(RSE)插入数据,如:
session.run("tableInsert{reactiveStateEngine}", bar)
但是,我想知道是否可以使用
multithreadedTableWriter
(MTW) 接口将数据写入 RSE。
本质上,引擎也可以通过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)