检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
订阅名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须字母或数字开头 最小长度：1 最大长度：128 description 否 String 订阅描述 最大长度：255 channel_id 是 String 所属事件通道ID sources 是 Array of SubscriptionSource
任务基本配置 表1 任务基本配置参数说明 参数 说明 任务名称 请输入任务名称 描述 请输入对本任务的描述。 配置“源端和目标端配置”。 当源端和目标端均为Kafka时： 图3 源端和目标端配置 源端类型：Kafka 目标端类型：Kafka 规格（QPS）：选择为2000、5000、9000、15000或＞20000。
请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。 图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明
Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/subscriptions/operation 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 请求参数
Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/subscriptions/obsbuckets 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2
配置是否开启批量推送，批量推送可帮您批量聚合多个事件。 批量推送条数 推送间隔 开启批量推送可见，每次批量推送的最大聚合条数，默认值100，输入值范围1~10000。 开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。 表3 批量推送示例 批量推送条数 推送间隔 实际发送效果 100条
支持CloudEvents SDK和API。 高并发&高可用 支持千万级事件并发。 服务可用性99.99%，采用分布式集群化部署，具备极强的容灾能力。 安全可靠 对接统一身份认证服务、云日志服务、云监控服务和云审计服务等安全管理服务，全方位保护事件的存储与访问。 持久化数据支持磁盘和用户指定密钥加密，进一步提高数据的安全性。
同账号下是下拉列表选择通道，且不能选择同一通道和default通道。 跨账号输入ID时不能输入同一通道ID和default通道ID，否则事件不通。 如果当前通道没有关联订阅，发布到该通道的消息将无法消费，所以需要新增订阅，下游事件订阅的事件源和上游订阅的事件源名称保持一致，且下游的事件源必须是自定义事件源。
事件订阅将事件源、事件通道和事件目标绑定在一起，通过事件规则将事件源发出的事件路由到事件目标。 一个订阅最多关联五个事件目标。 发布区域：华北-北京四、华东-上海一、华东-上海二 创建事件订阅 事件流 事件流对事件源产生的事件实时拉取、过滤及转换，并路由至事件目标，是一种更为实时、轻量和高效的端到端的流式数据处理场景。
创建事件订阅 subscription CreateSubscription 更新事件订阅 subscription UpdateSubscription 删除事件订阅 subscription DeleteSubscription 操作事件订阅 subscription OperateSubscription
作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Rocketmq实例”。 说明： 配置类型根据实例类型变更。
批量推送条数 开启批量推送可见，每次批量推送的最大聚合条数，默认值100，输入值范围1~10000。 推送间隔 开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。 单击“确定”，完成事件目标配置。 当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。
功能说明 本章节定义了事件订阅上报云监控服务的监控指标的监控指标列表和维度定义，您可以通过云监控服务的管理控制台来检索事件订阅产生的监控指标和告警信息，也可以通过事件网格EG控制台提供的“监控”页面来检索事件订阅产生的监控指标和告警信息。 监控指标 表1 监控指标说明 指标ID 指标名称
SSL证书将会下载到本地电脑，名字为“kafka-certs.zip”的文件。 参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件，在桶的根目录下上传“kafka-certs.zip”文件。 参考如下格式获取SASL证书地址:
单击订阅名称旁的，弹出“修改订阅”弹窗。 输入订阅名称和描述信息，单击“确定”，完成订阅名称和描述信息输入。 配置事件源。 配置如下事件源参数： 选择提供方：华为云 事件源：OBS应用事件源 桶：选择OBS桶 事件类型：下拉框中事件类型根据用户需求勾选 对象名前缀：若填写，符合规范才能触发事件。默认不填写，表示全匹配。
同账号下是下拉列表选择通道，且不能选择同一通道和default通道。 跨账号输入ID时不能输入同一通道ID和default通道ID，否则事件不通。 如果当前通道没有关联订阅，发布到该通道的消息将无法消费，所以需要新增订阅，下游事件订阅的事件源和上游订阅的事件源名称保持一致，且下游的事件源必须是自定义事件源。
Service，简称OBS）作为云服务事件源将产生的云服务事件发送到事件网格，事件规则对云服务事件进行过滤和转换，通过转换后的事件触发事件目标（即函数工作流服务中的函数）。 前提条件 已开通事件网格服务并授权。 已获取OBS和函数工作流的权限。 步骤一：创建事件目标（创建函数） 登录函数工作流控制台。 在左侧导航栏选择“函数
构建高可用性系统的需求。 项目 区域默认对应一个项目，这个项目由系统预置，用来隔离物理区域间的资源（计算资源、存储资源和网络资源），以默认项目为单位进行授权，用户可以访问您账号中该区域的所有资源。如果您希望进行更加精细的权限控制，可以在区域默认的项目中创建子项目，并在子项目中创建
告警类型 告警规则适用的告警类型，默认为指标。 资源类型 告警涉及资源类型，默认为事件网格。 维度 告警涉及的维度，默认为事件订阅。 监控范围 监控的范围，默认为指定资源。 监控对象 监控对象的选择，默认为事件订阅名称。 触发规则 触发告警的规则，默认为自定义创建。 告警策略 触发告警的告警策略，具体配置可参考表2。
告警类型 告警规则适用的告警类型，默认为指标。 资源类型 告警涉及资源类型，默认为事件网格。 维度 告警涉及的维度，默认为事件通道。 监控范围 监控的范围，默认为指定资源。 监控对象 监控对象的选择，默认为事件通道名称。 触发规则 触发告警的规则，默认为自定义创建。 告警策略 触发告
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
