检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
（可选）已创建自定义事件源。 已设置事件目标。 已创建企业项目，如何创建请参见管理项目和企业项目。 非企业用户和企业项目只有“default”时，该选项不显示。 拥有多个企业项目时，默认选择“default”。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。
oker数量、存储空间需保持一致。 确保vpc、子网、RocketMQ等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流＞专业版事件流作业”，进入“专业版事件流作业”页面。
可以查看审计日志，以便日后的审计和回溯。 日常操作 创建自定义事件源 事件通道 创建事件订阅 创建事件流 过滤规则参数说明 事件内容转换 网络管理 运维与监控 支持云审计的操作列表 查看云审计日志 事件监控 04 SDK 事件网格提供开源的CloudEvents SDK，并提供发
桶策略：选择“私有” 默认加密：不勾选 归档数据直读：选择“关闭” 企业项目：选择“default” 图1 创建桶 配置完成后，单击“立即创建”，根据提示信息完成桶的创建。 父主题： 实施步骤
默认存储类别 按需选择。 桶策略 按需选择。 默认加密 按需选择。 归档数据直读 按需选择。 企业项目 按需选择。 配置完成后，单击“立即创建”，根据提示信息完成桶的创建。 以上述流程构建源桶与目标桶。 父主题： 实施步骤
请输入Topic。 虚拟私有云 请选择虚拟私有云。 说明： 事件流创建之后不允许修改虚拟私有云，编辑会有异常提示。 子网 请选择子网。 说明： 事件流创建之后不允许修改子网，编辑会有异常提示。 SSL 请选择是否开启SSL。 ACL访问控制 请选择是否开启ACL访问控制。 说明： 当开启ACL访问控制时，需要配置用户名及密钥。
源端和目标端实例规格检查 检查源端实例和目标端实例的规格是否匹配。 对于预检查结果是告警或者失败的事件流作业，都不会阻塞事件流作业的创建流程，检查结果仅做提示用。 Kafka预检查 RocketMQ预检查 父主题： 专业版事件流
单击default通道后的“事件轨迹”。 图3 事件轨迹 进入事件轨迹页面，单击对应事件操作列的“事件轨迹”。 图4 投递详情 查看事件轨迹投递详情显示成功。 步骤四：在账号B中创建订阅去处理目标通道的事件 登录事件网格控制台。 在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。 单击“创建事件订阅”。
云上操作后，1分钟内可以通过云审计控制台查询管理类事件操作记录，5分钟后才可通过云审计控制台查询数据类事件操作记录。 CTS新版事件列表不显示数据类审计事件，您需要在旧版事件列表查看数据类审计事件。 在新版事件列表查看审计事件 登录管理控制台。 单击左上角，选择“管理与监管管理与部署
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
＞ 数字 每15分钟告警一次 重要 最小值 连续3次 ＜= 数字 每30分钟告警一次 次要 求和值 连续4次 ＜ 数字 每1小时告警一次 提示 方差值 连续5次 = 数字 每3小时告警一次 操作步骤 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择事件通道所在的区域。
桶策略：选择“私有” 默认加密：不勾选 归档数据直读：选择“关闭” 企业项目：选择“default” 图4 创建桶 单击“立刻创建”，根据提示信息完成桶的创建。 步骤四：查看结果 登录函数工作流控制台。 在左侧导航栏选择“函数 > 函数列表”，进入函数列表页面。 单击函数名称“test”，进入函数详情页。
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
String 指定查询的事件类型，精准匹配 subscription_name 否 String 事件订阅名称 limit 否 String 每页显示的条目数量，不能小于0 offset 否 Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 channel_id 是 String
Kafka参数说明 参数名称 说明 实例 选择Kafka实例。 接入方式 选择“密文接入”或“明文接入”。 安全协议 当选择为密文接入时会显示对应的安全协议。 Topic 选择Topic。 消费组 输入消费组名称，输入长度范围为3到64个字符。 Kafka实例未创建消费组时，事件
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
每隔1s批量推送100条消息 200条 5s 每隔5s批量推送500条消息 配置完成后，单击“确定”。 单击“事件流列表”操作列的“启用”，待状态列显示为“运行中”则代表整个链路创建成功。 测试验证 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15 sort 否 String 指定查询排序 缺省值：created_time:DESC
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
