datasystem.stream_client.Producer.send

datasystem.stream_client.Producer.send#

datasystem.stream_client.Producer.send(element_bytes, timeout_ms)#

生产者发送数据。

参数:
  • element_bytes (bytes) - 要发送的数据。

  • timeout_ms (int) - 接口超时时间, 单位ms。值为0时如果发送失败,将立刻返回错误原因。大于0时将会阻塞,等待完成。如果等待时间超过该值,则停止等待,并返回错误原因。

异常:
  • TypeError - 输入参数存在非法值。

  • RuntimeError - 发送失败。