Simple Log Service：消費者發送心跳到服務端

前提條件

參數說明

def heart_beat(self, project, logstore, consumer_group, consumer, shards=None):

請求參數

返回參數

請參見ConsumerGroupHeartBeat - 消費者發送心跳到服務端。

範例程式碼

from aliyun.log import LogClient
import os

# 本樣本從環境變數中擷取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', '')

# Log Service的服務存取點
endpoint = "cn-hangzhou.log.aliyuncs.com"

client = LogClient(endpoint, access_key_id, access_key_secret)

# Project名稱
project = "project-1"

# Logstore 名稱
logstore = "logstore-1"

# consumer_group 名稱
consumer_group = "consumer_group_test"

# shard的id列表
shards = [0, 1]

# 消費者名稱
consumer = ''

try:
    # 建立指定 Project 的 Consumer Group
    response = client.heart_beat(project, logstore, consumer_group, consumer, shards=None)
    response.log_print()
except Exception as e:
    print(f"An error occurred while creating the consumer group: {e}")

樣本返回結果

ListHeartBeat:
headers: {'Server': 'AliyunSLS', 'Content-Type': 'application/json', 'Content-Length': '5', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Fri, 25 Oct 2024 02:46:56 GMT', 'x-log-time': '1729824416', 'x-log-requestid': '671B06A0EE24B0B90621558E'}
shards: [0, 1]

相關文檔

• 消費日誌API介面請參見：

  • ListConsumerGroup - 查詢消費組

  • CreateConsumerGroup - 建立消費組

  • DeleteConsumerGroup - 刪除消費組

  • UpdateConsumerGroup - 更新消費者組

  • GetCheckPoint - 擷取指定消費組的消費點

  • ConsumerGroupUpdateCheckPoint - 更新消費進度

  • ConsumerGroupHeartBeat - 消費者發送心跳到服務端

• 更多範例程式碼，請參見Aliyun Log Python SDK on GitHub。