使用DeleteConsumerGroup接口删除指定名称的消费组。
前提条件
您已完成以下操作:
参数说明
def delete_consumer_group(self, project, logstore, consumer_group):
请求参数
参数 | 类型 | 是否必填 | 说明 |
project | String | 是 | Project的名称。 |
logstore | String | 是 | Logstore的名称。 |
consumer_group | String | 是 | 要删除的消费组名称。 |
返回参数
示例代码
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()
相关文档
文档内容是否对您有帮助?