全部產品
Search
文件中心

EventBridge:自訂事件來源Log ServiceSLS

更新時間:Nov 27, 2024

本文介紹如何在事件匯流排EventBridge控制台添加Log ServiceSLS類型的自訂事件來源。

前提條件

操作步驟

  1. 登入事件匯流排EventBridge控制台,在左側導覽列,單擊事件匯流排
  2. 在頂部功能表列,選擇地區,在事件匯流排頁面,單擊目標自訂事件匯流排名稱。
  3. 在左側導覽列,單擊事件來源,然後單擊添加事件來源
  4. 添加自訂事件來源面板,輸入名稱描述,將事件提供方選擇為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的唯一身份標識。