datasystem.stream_client.StreamClient.query_global_producer_num

datasystem.stream_client.StreamClient.query_global_producer_num#

datasystem.stream_client.StreamClient.query_global_producer_num(stream_name)#
指定流的名称,查询流的生产者数量。
参数:
  • stream_name (str) - 指定流的名称。

返回:

global_producer_num(int): 生产者的数量

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

  • RuntimeError - 查询生产者数量失败。