日志服务SLS

操作步骤

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。

3. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击保存。

   • 任务创建

     1. 在Source（源）配置向导，选择数据提供方为日志服务SLS，配置以下参数，然后单击下一步。

        参数	说明	示例
        日志项目	选择创建的日志服务SLS的Project。	test-Project
        日志库	选择创建的日志服务SLS的Logstore。	test-LogStore
        起始消费位点	起始消费位点，可以选择最早或最新位点，也可以从指定时间开始消费。	最新位点
        角色配置	授权事件总线EventBridge使用此角色读取SLS日志内容。角色的权限策略，请参见自定义事件源日志服务SLS。	testRole
        批量推送	批量推送可帮您批量聚合多个事件，当批量推送条数和批量推送间隔（单位：秒）两者条件达到其一时即会触发批量推送。 例如：您设置的推送条数为100 条，间隔时间为15 s，在10 s内消息条数已达到100条，那么该次推送则不会等15 s后再推送。	开启
        批量推送条数	调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1,10000]。	100
        批量推送间隔（单位：秒）	调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发给函数计算，取值范围为[0,15]，单位为秒。0秒表示无等待时间，直接投递。	3

     2. 在Filtering（过滤）、Transform（转换）及Sink（目标）配置向导，设置事件过滤、转换规则及事件目标。事件转换的配置说明，请参见使用函数计算实现消息数据清洗。

   • 任务属性

     设置事件流的重试策略及死信队列。更多信息，请参见重试和死信。

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系统字段解释，请参见保留字段。