检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
置相同,具体步骤,请参考创建私网访问端点。 用户default安全组规则配置不正确。 default安全组“出方向规则”需放通ICMP协议全部端口,具体步骤,请参考添加安全组规则。
配置分布式消息服务RabbitMQ版安全组“入方向规则”。详细操作,请参考添加安全组规则。 入方向规则需要放通的协议端口最小集需要包括: ICMP: 全部 TCP: 5672 TCP: 15672(从RabbitMQ实例的“基本信息”页面的“连接信息”页签中可以获取需要放通的TCP端口。) 图1
Image OBS应用事件源 对象存储服务 OBS 智能边缘平台 IEF 容器镜像服务 SWR 分布式缓存服务 DCS 弹性伸缩 AS 漏洞扫描服务 VSS 图引擎服务 GES 数据湖探索 DLI 云容器实例 CCI 需求管理 CodeArts Req 文档数据库服务 DDS 数据复制服务
性伸缩的云服务器。 部署web环境 什么是ECS 创建容器应用基本流程 快速创建一个kubernetes集群 3分钟创建一个游戏类容器应用 3分钟创建一个游戏类容器应用 3分钟创建一个游戏类容器应用 3分钟创建一个游戏类容器应用 05 API 事件网格提供了REST(Representational
创建事件流 本章节指导您如何在事件网格控制台创建事件流。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 单击“创建事件流”。 在弹窗中输入事件流名称和描述,单击“确定”,完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”,右侧弹出“事件源”弹窗。
Serverless版事件流概述 事件流对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标,是一种更为实时、轻量和高效的端到端的流式数据处理场景。 图1 事件流示意图 EG事件流目前处于公测阶段,欢迎您试用和体验相关的功能。 父主题: 事件流
当前同步的进度有100以内的误差。 副本数 请配置副本数。 自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 启动偏移量 请选择为“最早”或“最新”。 压缩算法 请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 Topic映射
事件订阅监控 事件订阅监控支持自定义时间跨度,可自定义选择查询的时间区间。 事件订阅支持多目标时,下拉选择目标后可查看指定监控,如不选择,则查看全部监控指标。 开启“自动刷新”后,指标数据会每5s刷新一次。 点击“查看更多指标详情”,可跳转至云监控CES界面。 当“周期”选择为原始值时
自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 同步消费进度 是。 说明: 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 否。 压缩算法 是,可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 单击“下一步:预检查
事件源是事件的来源,负责生产事件。事件网格支持以下事件源: 华为云服务事件源:华为云服务作为事件源,华为云服务包含弹性云服务器、对象存储服务和云容器引擎等等。 自定义事件源: 支持自定义应用通过事件网格提供的SDK接入,作为事件源。 支持分布式消息服务RabbitMQ版和分布式消息服务RocketMQ版作为自定义事件源。
管理Serverless版事件流 创建事件流 编辑事件流 删除事件流 RocketMQ采集函数错误码 父主题: 事件流
955Z", "data": { "name": "test01", "state": "enable" } },...] } 全部成功的返回体: {"failed_count":0,"events":[{"error_code":null,"error_msg":null
删除事件流 本章节指导您在控制台里删除事件流。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 在待删除的事件流所在行,单击“删除”,弹出“删除事件流”对话框。 单击“确定”,完成事件流的删除。 父主题: 管理Serverless版事件流
编辑事件流 事件流创建成功后,支持修改事件流的名称、描述、状态、事件源和事件目标。 修改事件流的名称和描述 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 在待修改描述信息的事件流所在行,单击“配置”,进入事件流详情页。 单击事件流名称旁的编辑图标,弹出“配置名称和描述”弹窗。
"EG.00015000", "error_msg" : "Internal Server Error" } 状态码 状态码 描述 200 启动或者停止事件流成功 400 非法请求 401 未授权 403 禁止访问 404 未找到资源 500 内部服务错误 错误码 请参见错误码。 父主题:
当选择“精确匹配”时需选择“Topics”。 同步消费进度 请选择是否打开。 说明: 开启时表示将消息消费进度同步到目标Rocketmq。 启动偏移量 请选择为“最早”、“最新”或“自定义”。 压缩算法 请选择压缩算法为“none”、“lz4”、“zstd”或“zlib”。 单击“
表示订阅TagA或TagB或TagC的消息。 开启保存消息轨迹 请选择是否开启保存消息轨迹。 启用鉴权认证 请选择是否启用鉴权认证。 Access Key(启用鉴权认证) 请输入Access Key。 Secret Key(启用鉴权认证) 请输入Secret Key。 订阅方式 请选择集群或广播。 接入点类型
duplicated 命名重复 请重新输入新名称 400 EG.00513002 invalid subscription status 启动中的订阅不能编辑 请稍后重试 400 EG.00513003 invalid target address 自定义事件目标url参数错误 请检查事件目标url参数
h(函数计算)时,执行方式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。 发送到目标端失败时,将利用Rocket
h(函数计算)时,执行方式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。 发送到目标端失败时,将利用Rocket