CreateConsumerGroup操作を呼び出して、コンシューマーグループを作成できます。 Simple Log Serviceを使用すると、サードパーティのソフトウェア、さまざまなプログラミング言語のアプリケーション、クラウドサービス、およびストリームコンピューティングフレームワークで、Simple Log Service SDKを呼び出すことでリアルタイムでデータを消費できます。 ただし、SDKベースの消費は、負荷分散や消費者間のフェイルオーバーなど、特定の実装詳細の要件を満たすことができません。 この場合、数秒以内にデータを消費するコンシューマグループを作成できます。
前提条件
Simple Log Serviceが有効化されています。 詳細については、「Simple Log Serviceの有効化」をご参照ください。
Python用のSimple Log Service SDKが初期化されます。 詳細については、「Simple Log Service SDK For Pythonの初期化」をご参照ください。
Parameters
def create_consumer_group(self, project, logstore, consumer_group, timeout, in_order=False):リクエストパラメーター
パラメーター | 型 | 必須 / 任意 | 説明 |
project | String | 対象 | プロジェクトの名前。 詳細については、「プロジェクトの管理」をご参照ください。 |
logstore | String | 対象 | ログストアの名前 詳細については、「Logstore の管理」をご参照ください。 |
consumer_group | String | 対象 | 消費者グループの名前です。 名前はLogstore内で一意である必要があります。 |
タイムアウト | int | 対象 | タイムアウト期間。 Simple Log Serviceがタイムアウト期間内にコンシューマーからハートビートを受信しない場合、Simple Log Serviceはコンシューマーを削除します。 単位は秒です。 |
in_order | bool | 非対象 | データを順番に消費するかどうかを指定します。 データがシャードで消費される順序は、データがシャードに書き込まれる順序と同じです。 このパラメーターは、分割またはマージ後に元のシャードと新しいシャードでデータが消費される順序にのみ影響します。 デフォルト値：False。 有効な値：
|
応答パラメーター
詳細については、「CreateConsumerGroup」をご参照ください。
サンプルコード
from aliyun.log import LogClient
import os
def main():
# In this example, the AccessKey ID and AccessKey secret are obtained from environment variables.
access_key_id = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
access_key_secret = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# The Simple Log Service endpoint.
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"
timeout = 30
in_order = False
try:
response = client.create_consumer_group(project, logstore, consumer_group, timeout, in_order)
response.log_print()
except Exception as e:
print(f"An error occurred while creating the consumer group: {e}")
if __name__ == '__main__':
main()
関連ドキュメント
データ消費関連のAPI操作の詳細については、以下のトピックを参照してください。
詳細なサンプルコードについては、GitHubの「Alibaba Cloud Simple Log Service SDK For Python」をご参照ください。