本文介绍如何在事件总线EventBridge控制台添加日志服务SLS作为事件流中的事件提供方。

背景信息

日志服务SLS是云原生观测与分析平台，为Log、Metric、Trace等数据提供大规模、低成本、实时的平台化服务。日志服务一站式提供数据采集、加工、查询与分析、可视化、告警、消费与投递等功能，提升您在研发、运维、运营、安全等场景的数字化能力。事件总线EventBridge支持实时从日志服务SLS获取事件，同时加载至事件目标，帮助您更加高效地对各种业务和运营事件做出响应。

操作步骤

  1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
  2. 在顶部菜单栏，选择地域，然后单击创建事件流。
  3. 在创建事件流面板，配置以下参数，然后单击创建。
    1. 在基本信息页签，设置事件流名称和描述，单击下一步。
    2. 在事件源页签，选择事件提供方为日志服务SLS，设置以下参数，然后单击下一步。
      参数 说明 示例
      日志项目 选择创建的日志服务SLS的Project。 test-Project
      日志库 选择创建的日志服务SLS的Logstore。 test-LogStore
      起始消费位点 起始消费位点，可以选择最早或最新位点，也可以从指定时间开始消费。 最新位点
      角色配置 授权事件总线EventBridge使用此角色读取SLS日志内容。角色的权限策略，请参见自定义事件源日志服务SLS。 testRole
    3. 在规则和目标页签，分别设置事件规则和事件目标。
    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系统字段解释，请参见保留字段。

参数 类型 示例值 描述
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的唯一身份标识。