yr.fnruntime.Consumer

class yr.fnruntime.Consumer

基类：object

Consumer接口类。

样例：

>>> try:
...     config = yr.SubscriptionConfig("subName", yr.SubscriptionConfig.subscriptionType.STREAM)
...     consumer = yr.create_stream_consumer("streamName", config)
...     # .......
...     elements = consumer.receive(6000, 1)
... except RuntimeError as exp:
...     # .......
...     pass

方法：

__init__
ack	消费者在处理完指定 elementId 的数据后需执行确认（ack）。
close	关闭消费者，释放内部资源。
receive	消费者接收数据。