subscriber = _events.getSubscriber()


def fn1(subscription):
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")


def fn2(it):
    _console.log("sub.py 收到事件", it.getData(), it.getTime(), it.getChannel())


subscriber.subscribeLocally(fn1, fn2)


def fn3(subscription):
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")


def fn4(it):
    _console.log("sub.py 收到事件", it.getData(), it.getTime(), it.getChannel())


subscriber.subscribeGlobally(fn3, fn4)
mainThread = _script.getThreads().getMain()
timer = mainThread.getTimer()


def fn5(params):
    # 保持脚本3秒钟不结束
    pass


timer.setTimeout(fn5, 3000)