检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
requireNonNull(EventFormatProvider.getInstance() .resolveFormat("application/cloudevents+json"))).withForceNonJsonDataToString();
最大长度:255 channel_id 否 String 指导事件源归属的事件通道ID type 否 String 事件源类型 缺省值:APPLICATION 枚举值: APPLICATION RABBITMQ ROCKETMQ detail 否 RocketMqDetail object json格式封装消息实例链接信息
RocketMQ预检查 源端和目标端实例版本检查 检查源端和目标端RocketMQ实例的版本是否符合要求,当前要求RocketMQ实例版本在5.x和4.8.0中,版本不在匹配名单中则提示告警。 原因一:源端RocketMQ实例版本不支持,请选择符合要求的实例。 解决方式:返回配置
https://iam.cn-north-1.myhuaweicloud.com/v3/auth/projects Content-Type: application/json X-Auth-Token: ABCDEFJ.... 您还可以通过这个视频教程了解如何使用Token认证:https://bbs
产品优势 稳定运行保障 高性能、高可靠。 数据一致性 预校验、一致性校验。 立体化监测无忧运维 监控定位、故障恢复。 数据处理 ETL,边同步边处理。 降低成本 规格丰富,按需计费。 降低开发成本 开箱即用,生态丰富,无码对接。 父主题: 专业版事件流
Kafka预检查 源端和目标端实例版本检查 检查源端和目标端实例的版本是否符合要求,当前要求Kafka实例版本在 3.x和2.7 中,版本不在匹配名单中则提示告警。 原因一:源端Kafka实例版本不支持,请选择符合要求的实例。 解决方式:返回配置专业版事件流作业的第二步,即“源和
端Kafka的Broker数量。 启动偏移量 请选择为“最早”或“最新”。 压缩算法 请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 Topic映射 请输入要映射的源端Topic和目标端Topic名称,单击“保存”。 如果源端和目标端的k
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时,目标端只支持选择FunctionGraph(函数计算)。
开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 请选择为“最早”或“最新”。 压缩算法 请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 单击“下一步:预检查”,进入“预检查”页面,完成后单击“完成配置”。 图3 预检查 返回专业版事件流作业
查看事件消息格式。 查看事件轨迹的事件详情: 图7 事件轨迹详情 消息体事件格式如下: { "datacontenttype": "application/json", "data": { "context": "{\"hello\":\"world\"}",
进入事件轨迹页面后,单击“事件ID”列表中的事件名称,即可查看事件详情。 图9 查看事件详情 消息体事件格式如下: { "datacontenttype": "application/json", "data": { "context": "11111" }, "subject": "RABBITMQ:
社区版RocketMQ 本章节介绍在事件流里添加社区版RocketMQ事件源的方法。 目前支持RocketMQ的开源版本:4.9.7/5.1.4。 前提条件 已有社区版RocketMQ集群实例。 当源端为社区版RocketMQ时,目标端只支持选择FunctionGraph(函数计算)。
移动云RocketMQ版 本章节介绍在事件流里添加移动云 RocketMQ版事件源的方法。 目前支持region:上海二 前提条件 已在移动云购买RocketMQ实例。 当源端为移动云RocketMQ时,目标端只支持选择FunctionGraph(函数计算)。 创建移动云 RocketMQ版事件源
json.dumps(event), "headers": { "Content-Type": "application/json" } } 步骤四:创建事件订阅 事件订阅将事件源、通道和事件目标绑定在一起,通过事件规则将事件源发出的事件路由到事件目标。
"specversion": "1.0", "type": "blob_created", "datacontenttype": "application/json", "dataschema": "https://github.com/cloudevents/cloudevent
获取obs桶列表 功能介绍 获取obs桶列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/subscriptions/obsbuckets