yr.fnruntime.Producer

class yr.fnruntime.Producer

基类：object

Producer接口类。

样例：

>>> try:
...     producer_config = yr.ProducerConfig(
...         delay_flush_time=5,
...         auto_clean_up=True,
...     )
...     producer = yr.create_stream_producer("streamName", producer_config)
...     # .......
...     data = b"hello"
...     element = yr.Element(data=data, id=0)
...     producer.send(element)
...     producer.flush()
...     producer.close()
... except RuntimeError as exp:
...     # .......
...     pass

方法：

__init__	初始化 Producer 实例。
close	关闭生产者将触发数据缓冲区的自动刷新，并表明数据缓冲区不再使用。
send	生产者发送数据时，会先将数据存入缓冲区。