database - 不能在 DolphinDB 的函数定义中声明 share 语句

Question

我正在尝试 dolphindb 的流处理功能。我希望另一个节点订阅当前节点，所以我写了一些如下代码。但是 dolphindb GUI 以某种方式报告Syntax Error: [line #2] share statement can't be declared within a function definition.这是否意味着，我必须打开另一个会话，然后NODE2手动连接并订阅？

def mySub(PUBNODE, src) {
    share streamTable(1:0, [`c1], [INT]) as t
    subscribeTable(server=PUBNODE, tableName = src, handler = objByName(`t))
}

share streamTable(1:0, [`c1], [INT]) as `src
rpc(NODE2, mySub, getNodeAlias(), `src)

Answer 1

请使用共享功能跨会话共享流表。

def mySub(PUBNODE, src) {
    share(streamTable(1:0, [`c1], [INT]), "t")
    subscribeTable(server=PUBNODE, tableName = src, handler = objByName(`t))
}