EventBridge：Log ServiceSLS

操作步驟

1. 登入事件匯流排EventBridge控制台，在左側導覽列，單擊事件流。
2. 在頂部功能表列，選擇地區，然後單擊建立事件流。

3. 在创建事件流面板，設定任务名称和描述，配置以下參數，然後單擊儲存。

   • 任務建立

     1. 在Source（源）設定精靈，選擇数据提供方為Log ServiceSLS，配置以下參數，然後單擊下一步。

        參數	說明	樣本
        記錄項目	選擇建立的Log ServiceSLS的Project。	test-Project
        日誌庫	選擇建立的Log ServiceSLS的Logstore。	test-LogStore
        起始消費位點	起始消費位點，可以選擇最早或最新位點，也可以從指定時間戳記（以秒錶示的Unix時間戳記）開始消費。	最新位點
        角色配置	授權事件匯流排EventBridge使用此角色讀取SLS日誌內容。角色的權限原則，請參見自訂事件來源Log ServiceSLS。	testRole
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

     2. 在Filtering（过滤）、Transform（转换）及Sink（目标）設定精靈，設定事件過濾、轉換規則及事件目標。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。

   • 任務屬性

     設定事件流的重試策略及無效信件佇列。更多資訊，請參見重試和死信。

4. 返回事件流頁面，找到建立好的事件流，在其右側操作欄，單擊啟用。

   啟用事件流後，會有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",
        "__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系統欄位解釋，請參見保留欄位。