このトピックでは、[EventBridge] コンソールで Simple Log Service をイベントプロバイダーとするイベントストリームを作成する方法について説明します。
始める前に
背景情報
Simple Log Service は、ログ、メトリクス、トレースなど、さまざまな種類のデータを処理する大規模、低コスト、リアルタイムのサービスを提供する、クラウドネイティブの可観測性および分析プラットフォームです。 Simple Log Service は、研究開発、運用管理、データセキュリティにおけるデジタル機能の向上を支援するワンストッププラットフォームです。 データの収集、変換、クエリ、分析、消費、配信を視覚的に行うことができます。 また、Simple Log Service コンソールでアラートを設定することもできます。 [EventBridge] を使用すると、Simple Log Service からリアルタイムでイベントを取得し、イベントターゲットにロードできます。 これにより、さまざまなビジネスイベントや運用イベントに効率的に対応できます。
手順
[EventBridge] コンソールにログオンします。 左側のナビゲーションペインで、[イベントストリーム] をクリックします。
上部のナビゲーションバーで、リージョンを選択し、[イベントストリームの作成] をクリックします。
イベントストリームの作成 ページで、タスク名 パラメーターと 説明 パラメーターを設定し、画面の指示に従って他のパラメーターを設定します。 次に、[保存] をクリックします。 次のセクションでは、パラメーターについて説明します。
タスクの作成
Source (ソース) ステップで、データプロバイダー パラメーターを [simple Log Service] に設定し、画面の指示に従って他のパラメーターを設定します。 次に、[次のステップ] をクリックします。 次の表に、パラメーターを示します。
パラメーター
説明
例
[プロジェクト]
作成した Simple Log Service プロジェクトを選択します。
test-Project
[ログストア]
作成した Simple Log Service Logstore を選択します。
test-LogStore
[コンシューマーオフセット]
メッセージの消費を開始するオフセットを指定します。 有効な値: 最初のオフセット、最新のオフセット、指定時刻。
最新のオフセット
[ロール]
[EventBridge] が Simple Log Service のログを読み取るためにアシュームするロールを指定します。 ロールのポリシーについては、Simple Log Service タイプのカスタムイベントソースの作成を参照してください。
testRole
一括プッシュの件数
関数呼び出しごとに送信できるメッセージの最大数。 バックログ内のメッセージ数が指定された値に達した場合にのみ、リクエストが送信されます。 有効な値: 1 ~ 10000。
100
バッチプッシュ間隔 (単位:秒)
関数を呼び出す時間間隔。 システムは、指定された時間間隔で集約されたメッセージを Function Compute に送信します。 有効な値: 0 ~ 15。 単位: 秒。 値 0 は、集約後にメッセージがすぐに送信されることを示します。
3
Filtering (フィルタリング) 、Transform (変換) 、Sink (ターゲット) ステップで、イベントフィルタリング方法、イベント変換ルール、イベントターゲットを設定します。 イベント変換設定については、Function Compute を使用したメッセージクレンジングを参照してください。
タスクのプロパティ
イベントストリームの再試行ポリシーとデッドレターキューを設定します。 詳細については、「再試行ポリシーとデッドレターキュー」をご参照ください。
[イベントストリーム] ページに戻り、作成したイベントストリームを見つけます。 次に、[アクション] 列の [有効化] をクリックします。
イベントストリームの有効化には、30 ~ 60 秒かかります。 [イベントストリーム] ページのイベントストリームの [ステータス] 列で進捗状況を確認できます。
サンプルイベント
{
"datacontenttype": "application/json;charset=utf-8",
"aliyunaccountid": "175299981560****",
"data": {
"key1": "value1",
"key2": "value2",
"__topic__": "test_topic", // ログトピック
"__source__": "test_source", // ログが収集されたデバイス
"__client_ip__": "122.231.XX.XX", // ログが存在するホストの IP アドレス
"__receive_time__": "1663487595", // ログがサーバーに到着した時刻
"__pack_id__": "59b662b2257796****" // ログが属するロググループの固有 ID
},
"subject": "acs:log:cn-qingdao:175299981560****:project/qiingdaoproject/logstore/qingdao-logstore-1",
"aliyunoriginalaccountid": "175299981560****",
"source": "test-SLS",
"type": "sls:connector",
"aliyunpublishtime": "2022-09-18T07:53:15.387Z",
"specversion": "1.0",
"aliyuneventbusname": "qingdaoBus",
"id": "qiingdaoproject-qingdao-logstore-1-1-MTY2MzExODM5ODY4NjAxOTQyMw****",
"time": "2022-09-18T07:53:12Z",
"aliyunregionid": "cn-qingdao",
"aliyunpublishaddr": "10.50.XX.XX"
}CloudEvents 仕様で定義されているパラメーターについては、「概要」をご参照ください。
次の表に、data に含まれるパラメーターを示します。 アンダースコア (_) で囲まれたパラメーターは、Simple Log Service のシステムフィールドです。 詳細については、「予約フィールド」をご参照ください。
パラメーター | タイプ | 例 | 説明 |
key1 | String | testKey | ユーザーのログのフィールド。 |
__topic__ | String | testTopic | ログトピック。 |
__source__ | String | testSource | ログが収集されたデバイス。 |
__client_ip__ | String | 122.231.XX.XX | ログが存在するホストの IP アドレス。 |
__receive_time__ | String | 1663487595 | ログがサーバーに到着した時刻。 |
__pack_id__ | String | 59b662b2257796**** | ログが属するロググループの固有 ID。 |