操作步驟

1. 登錄事件總線EventBridge控制臺(tái)，在左側(cè)導(dǎo)航欄，單擊事件總線。
2. 在頂部菜單欄，選擇地域，在事件總線頁面，單擊目標(biāo)自定義事件總線名稱。
3. 在左側(cè)導(dǎo)航欄，單擊事件源，然后單擊添加事件源。

4. 在添加自定義事件源面板，輸入名稱和描述，將事件提供方選擇為日志服務(wù)SLS，配置以下參數(shù)，然后單擊確認(rèn)。

   • 日志項(xiàng)目：選擇已創(chuàng)建的Project。

   • 日志庫：選擇已創(chuàng)建的Logstore。

   • 起始消費(fèi)位點(diǎn)：起始消費(fèi)位點(diǎn)，可以選擇最早或最新位點(diǎn)，也可以從指定時(shí)間戳（以秒表示的Unix 時(shí)間戳）開始消費(fèi)。

   • 角色配置：授權(quán)事件總線EventBridge使用此角色讀取SLS日志內(nèi)容。

     • 事件總線EventBridge使用您提供的角色來讀取SLS日志時(shí)，會(huì)在LogStore下自動(dòng)創(chuàng)建一個(gè)以“eventbridge-”開頭的消費(fèi)組，任務(wù)釋放后會(huì)將此消費(fèi)組清理。

     • 您提供的角色應(yīng)保證事件總線EventBridge可以讀取對(duì)應(yīng)LogStore日志與消費(fèi)組的增刪操作，至少賦予角色LogStore消費(fèi)權(quán)限與消費(fèi)組的增刪操作。權(quán)限策略請(qǐng)參考以下代碼。更多信息，請(qǐng)參見權(quán)限策略和示例。

       {
         "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規(guī)范中定義的參數(shù)解釋，請(qǐng)參見事件概述。

data字段包含的參數(shù)解釋如下表所示，其中以“__”開頭和結(jié)尾的為SLS系統(tǒng)字段解釋，請(qǐng)參見保留字段。