检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
专享版事件流架构示意图 当前仅支持华南-广州。 功能简介 引导式同步 使用EG专享版事件流秒变同步专家。 场景化选择 预设使用场景,让数据同步更少配置、更简单。 网络与安全 支持SSL等加密和认证机制,让数据同步更安全。 多种同步模式 支持对象选择、全量+增量同步和多种压缩模式,满足不同同步诉求。
代码检查 CodeCheck 云数据库GaussDB NoSQL GaussDB API网关 APIG 数据仓库服务 DWS 部署 CloudDeploy 统一身份认证 IAM 事件网格 EG 华为云 UCS 弹性文件服务 SFS CloudIDE 人脸识别 FRS 微服务引擎 CSE
状态码 状态码如表1所示 表1 状态码 状态码 编码 错误码说明 100 Continue 继续请求。 这个临时响应用来通知客户端,它的部分请求已经被服务器接收,且仍未被拒绝。 101 Switching Protocols 切换协议。只能切换到更高级的协议。 例如,切换到HTTP的新版本协议。
监控 查看监控数据 支持的监控指标 配置监控告警 父主题: 事件订阅
监控 查看监控数据 支持的监控指标 配置监控告警 父主题: 事件通道
监控 查看监控数据 支持的监控指标 配置监控告警 父主题: 事件流
专享版事件流作业 创建专享版事件流作业 删除专享版事件流作业 启用专享版事件流作业 停用专享版事件流作业 配置专享版事件流作业 父主题: 专享版事件流
自定义事件源 100 自定义事件源-RabbitMQ 5 自定义事件源-RocketMQ 5 事件通道 10 事件订阅 20 单个事件订阅能够配置的事件目标 5 事件流 20 目标连接 3 私网访问端点 10 如果当前资源配额限制无法满足使用需要,您可以申请扩大配额。配额查看及修改请参见关于配额。
默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图1 创建桶 配置完成后,单击“立即创建”,根据提示信息完成桶的创建。 父主题: 实施步骤
检查发布事件的请求方法、请求地址和请求体与利用验签算法生成签名时的参数是否一致。 资源不存在。 请检查事件通道、事件源、事件订阅等是否创建成功并且正确配置。 事件体的格式不正确。 请检查事件是否符合CloudEvents协议标准格式,特别注意使用序列化框架序列化后属性的大小写有没有改变。
构造请求 本节如何构造REST API的请求,并以调用IAM服务的获取用户Token说明如何调用API,该API获取用户的Token,Token可以用于调用其他API时鉴权。 您还可以通过这个视频教程了解如何构造请求调用API:https://bbs.huaweicloud.com/videos/102987。
在左侧导航栏选择“网络管理>访问端点”,进入“访问端点”页面。 单击“创建访问端点”,弹出“创建访问端点”对话框。 参考表 访问端点参数说明,填写访问端点的配置信息。 表2 访问端点参数说明 参数 说明 名称 您自定义的访问端点名称。 访问端点创建成功后,访问端点名称不支持修改。 虚拟私有云 选择虚拟私有云,需提前创建。
事件网格如何收费? 事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。
专享版事件流预检查 当前仅支持华南-广州。 预检查是创建事件流作业流程中的一环,用来检查用户填写的配置信息是否符合要求。预检查包含多个检查项,详情请参考表1,且每项检查独立执行,检查结果分成功、失败和告警三种类型。 表1 检查项目介绍 项目 内容 源端和目标端实例版本检查 检查源端实例和目标端实例的版本是否匹配。
认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leader已经成功将数据写
rule_config 否 rule_config object 事件规则,包括过滤规则和转换规则 option 否 RunOption object 运行时配置信息 表4 EventStreamingSource 参数 是否必选 参数类型 描述 source_kafka 否 SourceKafkaMQParameters
agency_name 是 String 委托名称 id 是 String 需要翻新的触发器id transform 是 TransForm object 规则配置 表4 TransForm 参数 是否必选 参数类型 描述 type 是 String 转换规则类型 枚举值: ORIGINAL CONSTANT
CloudEvents SDK 本章节介绍使用开源的CloudEvents Java SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。
的ID。 同账号跨区域时目标通道也需要开启跨账号开关,输入本账号的ID。 账号ID 请输入被授权账号ID,多账号以逗号分隔。 说明: 支持配置最多3个账号,多账号以逗号分隔,如:“account1,account2”。 策略 { "Sid": "allow_account_to_put_events"
认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leader已经成功将数据写