本文介紹如何在事件匯流排EventBridge控制台添加Log ServiceSLS類型的自訂事件來源。
前提條件
Log ServiceSLS
事件匯流排EventBridge
操作步驟
- 登入事件匯流排EventBridge控制台,在左側導覽列,單擊事件匯流排。
- 在頂部功能表列,選擇地區,在事件匯流排頁面,單擊目標自訂事件匯流排名稱。
- 在左側導覽列,單擊事件來源,然後單擊添加事件來源。
在添加自訂事件來源面板,輸入名稱和描述,將事件提供方選擇為Log ServiceSLS,配置以下參數,然後單擊確認。
記錄項目:選擇已建立的Project。
日誌庫:選擇已建立的Logstore。
起始消費位點:起始消費位點,可以選擇最早或最新位點,也可以從指定時間戳記(以秒錶示的Unix 時間戳記)開始消費。
角色配置:授權事件匯流排EventBridge使用此角色讀取SLS日誌內容。
事件匯流排EventBridge使用您提供的角色來讀取SLS日誌時,會在LogStore下自動建立一個以“eventbridge-”開頭的消費組,任務釋放後會將此消費組清理。
您提供的角色應保證事件匯流排EventBridge可以讀取對應LogStore日誌與消費組的增刪操作,至少賦予角色LogStore消費許可權與消費組的增刪操作。權限原則請參考以下代碼。更多資訊,請參見權限原則和樣本。
{ "Version": "1", "Statement": [ { "Action": [ "log:ListShards", "log:GetCursorOrData", "log:GetConsumerGroupCheckPoint", "log:UpdateConsumerGroup", "log:ConsumerGroupHeartBeat", "log:ConsumerGroupUpdateCheckPoint", "log:ListConsumerGroup", "log:CreateConsumerGroup", "log:DeleteConsumerGroup" ], "Resource": [ "acs:log:*:*:project/<指定的project名稱>/logstore/<指定的Logstore名稱>", "acs:log:*:*:project/<指定的project名稱>/logstore/<指定的Logstore名稱>/*" ], "Effect": "Allow" } ] }
事件樣本
{
"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",
"__receive_time__": "1663487595",
"__pack_id__": "59b662b2257796****"
},
"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欄位包含的參數解釋如下表所示,其中以“__”開頭和結尾的為SLS系統欄位解釋,請參見保留欄位。
參數 | 類型 | 樣本值 | 描述 |
key1 | String | testKey | "key1": "value1"、"key2": "value2"表示使用者的SLS日誌中的欄位及對應內容。 |
__topic__ | String | testTopic | 日誌主題。 |
__source__ | String | testSource | 日誌來源裝置。 |
__client_ip__ | String | 122.231.XX.XX | 日誌所在主機的IP地址。 |
__receive_time__ | String | 1663487595 | 日誌到達服務端的時間。 |
__pack_id__ | String | 59b662b2257796**** | 該日誌所屬的LogGroup的唯一身份標識。 |