删除消费组

使用DeleteConsumerGroup接口删除指定名称的消费组。

前提条件

您已完成以下操作:

参数说明

def delete_consumer_group(self, project, logstore, consumer_group):

请求参数

参数

类型

是否必填

说明

project

String

Project的名称。

logstore

String

Logstore的名称。

consumer_group

String

要删除的消费组名称。

返回参数

请参见DeleteConsumerGroup - 删除消费组

示例代码

from aliyun.log import LogClient
import os


def main():
    # 本示例从环境变量中获取AccessKey ID和AccessKey Secret
    access_key_id = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
    access_key_secret = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
    # 日志服务的服务接入点
    endpoint = "cn-hangzhou.log.aliyuncs.com"

    client = LogClient(endpoint, access_key_id, access_key_secret)

    project = "ali-test-peoject"
    logstore = "test-logstore"
    consumer_group = "consumer_group_test"

    try:
        response = client.delete_consumer_group(project, logstore, consumer_group)
        response.log_print()
    except Exception as e:
        print(f"An error occurred while creating the consumer group: {e}")


if __name__ == '__main__':
    main()

相关文档