进阶功能

from threading import Timer
from blockdb import Subscribe

sub = Subscribe(tables=['chain.event.eth'])
timer = Timer(30, sub.close)
timer.start()
try:
    for table_id, block in sub.listen():
        print(table_id, block.id, block.height, block.timestamp)
        break
finally:
    sub.close()
    timer.cancel()

from blockx import InputsCallConfig, ReturnValueHandler, TaskBuilder

config = InputsCallConfig(
    func='demo.usdc_amount',
    callList=[[1500000], [2000000]],
)
result = TaskBuilder.build(config, ReturnValueHandler()).submit(timeout=30)

if not result.task_result.success:
    raise RuntimeError(result.error)
print(sorted(result.handler_result))

from chaintable import variables

network = variables.get('DOCS_NETWORK', 'eth')
print(network)