您可以通过事件规则过滤事件,将事件路由到对象存储OSS服务,本文以自定义事件为例介绍将事件路由到对象存储OSS服务的前提条件、操作步骤和结果验证。
前提条件
步骤一:添加自定义事件源
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域,在事件总线页面,单击目标自定义事件总线名称。
- 在左侧导航栏,单击事件源,然后单击添加事件源。
在添加自定义事件源面板,输入名称和描述,事件提供方选择自定义应用,然后单击确定。
步骤二:创建事件规则
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域,在事件总线页面,单击目标总线名称。
- 在左侧导航栏,单击事件规则,然后单击创建规则。
在创建规则面板,完成以下操作。
在配置基础信息页签,自定义规则名称和规则描述,然后单击下一步。
在配置事件模式页签,选择事件源类型为自定义事件源,并选择已创建的事件源,然后单击下一步。
在配置事件目标页签,配置以下信息,然后单击创建。
配置项
示例
说明
服务类型
对象存储OSS
在下拉列表中选择对象存储OSS。
OSS Bucket
test
在下拉列表中选择已创建的Bucket。
保存路径
/EB-test/
定义数据在OSS Bucket中的存储路径。
说明保存路径支持多种定义方式:
JSONPath 规则:支持使用 JSONPath 规则自定义 OSS 路径参数,例如:
{$.data}
、{$.data.partition}
。时间变量:支持使用
{yyyy}
、{MM}
、{dd}
、{HH}
等时间变量参数。常量:支持直接填写常量字符串。
保存路径必须以
/
结尾。
时区配置
Asia/China(UTC+8:00)
如果您选择以时间变量来设置保存路径,需要在下拉框中选择该时间变量所基于的时区。
投递配置
批量聚合文件大小 (MiB):128MiB
批量聚合时间窗口 (分钟):60分钟
支持以下配置:
批量聚合文件大小:指定了达到多少MiB时(取值范围为1-1024MiB),即使未到达设定的时间窗口,也会将当前累积的数据作为一个批次发送到OSS。
批量聚合时间窗口:指定了多长分钟后(取值范围为1-1440分钟),即使文件大小未达到设定的阈值,也会将当前累积的数据作为一个批次发送到OSS。
文件压缩
无需压缩
选择是否对文件进行压缩以及使用的压缩算法:
无需压缩
GZIP
Snappy
Zstd
文件内容
完整事件
支持完整事件和部分事件,如果您选择部分事件,请参见部分事件进行配置。
重试和死信
无
具体配置方法,请参见重试和死信。
说明部署过程大约需要1分钟,请您耐心等待。
步骤三:发布事件
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域。
在事件总线页面,找到目标总线,在其右侧操作列单击发布事件。
说明仅自定义事件总线支持通过控制台发布事件。
在发布事件至自定义事件总线面板,自定义事件源下拉列表选择已创建的自定义事件源,在事件体代码框输入事件内容,然后单击确定。
说明事件包含的参数规范,请参见事件概述。
单击确定后,会默认复制事件ID。
结果验证
登录OSS管理控制台。
在左侧导航栏单击Bucket列表,然后在Bucket列表页面单击目标Bucket名称。
在目标Bucket的文件列表页面,单击目标文件名称(本文示例文件名为
EB-test/
)。单击目标文件操作列的详情,即可查看具体信息。