检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
目标连接管理 创建目标连接 查询目标连接列表 更新目标连接 查询目标连接详情 删除目标连接 父主题： API
事件发布失败的原因？ 事件发布失败，可能是以下原因导致： 接口无访问权限。 检查AK/SK是否正确，如果需要重新获取AK/SK，请参考获取AK/SK。 请求鉴权失败。 检查发布事件的请求方法、请求地址和请求体与利用验签算法生成签名时的参数是否一致。 资源不存在。 请检查事件通道、
client.execute(httpPost); } } 参数说明： NAME：IAM用户名。 PASSWORD：IAM 用户密码。 DOMAIN_NAME：IAM domain用户名。 IAM_ENDPOINT：IAM的终端节点，您可以从地区和终端节点中查询服务的终端节点。
API 事件订阅管理 事件通道管理 事件管理 事件源管理 事件目标分类管理 事件模型管理 目标连接管理 服务委托管理 配额管理 API版本管理 触发器管理 访问端点管理 obs桶管理 监控指标管理 事件流管理 事件示例管理
基于Serverless版事件流实现Kafka实例之间的数据同步 本章节介绍如何通过事件网格服务的事件流功能实现分布式消息服务Kafka版实例间的数据同步。 基于EventGrid事件订阅和Function实现OBS桶数据同步 本章节介绍如何通过事件网格服务的事件订阅和函数工作流服务实现OBS桶的数据同步。
SSL时可见，输入SASL证书密钥。 用户名 当Kafka实例开启SASL SSL时可见，输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。 目标端配置操作步骤 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。
这两种事件模型都存储在Schema注册表中，事件目标可以从Schema注册表中获取事件Schema的定义，实现快速访问事件。 事件网格的Schema遵循OpenSchema规范。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件模型”，进入“事件模型”页面。 单击“自定义事件模型”，弹出“创建自定义事件模型”对话框。
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建
00513002、EG.00513003、EG.00513006、EG.00512002、EG.00512003错误码。 2022-09-27 新增目标连接管理、访问端点管理等API接口。 2022-08-19 修改错误码前缀名称。 2022-06-07 第一次正式发布。
新选择符合实例版本要求的实例作为源端实例。 原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专业版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。 检查源端和目标端RocketMQ实例的版本是否一致，版本不一致则提示告警。
面，重新选择符合实例版本要求的实例作为源端实例。 原因二：目标端Kafka实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专业版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。 检查源端和目标端Kafka实例的版本是否一致，版本不一致则提示告警。
购买Kafka实例 购买实例 登录分布式消息服务Kafka版控制台，单击页面右上方的“购买Kafka实例”。 配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。 计费模式：按需计费 区域：与事件网格所在区域保持一致 项目：选择默认项目 可用区：根据默认项配置
ents规范。 事件网格支持的事件如下。 华为云服务事件：华为云服务事件源产生的事件。 自定义事件：您自定义的事件源接入事件网格产生的事件。您需要自行使用SDK接入事件网格。 约束与限制 单事件大小限制：64K。 单条请求所有事件总大小限制：256K。 单条请求事件数量限制：20条。
触发器类型：选择“分布式消息服务（Kafka）”。 实例：选择与死信队列相同的Kafka实例。 主题：选择与死信队列相同的Topic。 批处理大小：每次从Topic消费的消息数量，建议设置为10。 用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。 密码：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的密码。
Payment Required 保留请求。 403 Forbidden 请求被拒绝访问。 返回该状态码，表明请求能够到达服务端，且服务端能够理解用户请求，但是拒绝做更多的事情，因为该请求被设置为拒绝访问，建议直接修改该请求，不要重试该请求。 404 NotFound 所请求的资源不存在。
用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Kafka实例 请选择Kafka实例。 接入方式 支持“明文接入”或“密文接入”。 安全协议 当选择明文接入时，安全协议为“PLAINTEXT”。 当选择“密文接入”时，安全协议可选择“SASL_S
已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组。 已购买分布式消息服务RocketMQ实例。 已创建函数，函数以Python3.9运行时为例介绍。 创建Serverless版事件流 登录事件网格控制台，左侧导航栏选择“事件流 > Serverless版事件流”，右上角单击“创建
本章节提供实现图片压缩功能的程序包，使用空白模板创建函数，样例代码请参见使用函数压缩图片。 创建函数（创建函数的时候，必须选择包含OBS访问权限的委托，否则不能使用OBS服务）。 登录函数工作流控制台，在左侧导航栏选择“函数 > 函数列表”，进入函数列表界面。 单击“创建函数”，进入创建函数流程。
pub_num 接入事件数量 该指标为单位时间通道接入事件数量 ≥ 0 事件通道 1分钟 pub_success_num 接入事件成功数量 该指标为单位时间通道接入事件成功数量 ≥ 0 事件通道 1分钟 pub_success_rate 接入事件成功率 该指标为单位时间通道接入事件成功率
已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。 相关监控指标 2023年9月30日上线。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
