爆款云主机低至1.5折起,Token套餐低至9.9元/月起!
查看详情

活动

天翼云最新优惠活动,涵盖免费试用,产品折扣等,助您降本增效!
热门活动
  • 818 天翼云云智盛典 NEW 爆款云主机低至1.5折起,Token套餐低至9.9元/月起
  • 安全隔离版OpenClaw NEW OpenClaw云服务器专属“龙虾“套餐低至1.5折起
  • 聚力AI赋能 天翼云大模型专项 大模型特惠专区·Token Plan 轻享包低至9.9元起
  • 青云志云端助力计划 NEW 一站式科研助手,海外资源安全访问平台,助力青年翼展宏图,平步青云
  • 企业出海解决方案 NEW 助力您的业务扬帆出海,通达全球!
  • 天翼云信创专区 NEW “一云多芯、一云多态”,国产化软件全面适配,国产操作系统及硬件芯片支持丰富
  • 云上钜惠 爆款云主机全场特惠,2核4G只要1.8折起!
  • 天翼云奖励推广计划 加入成为云推官,推荐新用户注册下单得现金奖励
免费活动
  • 免费试用中心 HOT 多款云产品免费试用,快来开启云上之旅
  • 天翼云用户体验官 NEW 您的洞察,重塑科技边界

息壤智算

领先开放的智算服务平台,提供算力、平台、数据、模型、应用“五位一体”智算服务体系,构建全流程的AI基础设施能力
星辰TokenHub
  • 模型广场
  • 体验中心
  • 服务接入
星辰MaaS平台
  • 星辰MaaS智能体平台
  • 星辰大模型
大模型
  • DeepSeek-V4-Flash
  • GLM-5.1
  • Qwen3.5-122B-A10B
  • DeepSeek-V3.2(旗舰版)
  • GLM-5(正式版)
AI Store
  • 算力市场
  • 模型市场
  • 应用市场
应用托管
  • 应用实例
科研助手
  • 科研智能体
  • 科研服务
  • 开发机
  • 并行计算
训推服务
  • 模型开发
  • 训练任务
  • 服务部署
智能体引擎
  • 智能体引擎
可信数据空间
  • 可信数据空间
公共算力服务
  • 裸金属
  • 定制裸金属
智算一体机
  • 智算一体机
模型适配专家服务
  • 模型适配专家服务
算力服务商
  • 入驻算力服务商

应用商城

天翼云精选行业优秀合作伙伴及千余款商品,提供一站式云上应用服务
进入甄选商城进入AI Store公有云生态专区智云上海应用生态专区
建站工具
  • 新域名服务
  • SSL证书
  • 翼建站
企业办公
  • 智教云电脑
  • WPS 365 天翼云版
灾备迁移
  • 云管家2.0
  • 翼备份(SaaS版)
  • 琥珀数据压缩归档服务
智慧教育
  • 智擎思政平台(个人版)
  • 智擎研学平台(个人基础版)

定价

协助您快速了解云产品计费模式、价格详情,轻松预估上云成本
价格计算器
  • 动态测算产品价格
定价策略
  • 快速了解计费模式

合作伙伴

天翼云携手合作伙伴,共创云上生态,合作共赢
天翼云生态合作中心
  • 天翼云生态合作中心
天翼云渠道合作伙伴
  • 天翼云代理渠道合作伙伴
天翼云服务合作伙伴
  • 天翼云集成商交付能力认证
天翼云应用合作伙伴
  • 天翼云甄选商城合作伙伴
天翼云技术合作伙伴
  • 天翼云OpenAPI中心
天翼云培训认证
  • 天翼云学堂
天翼信创云专区
  • 信创云专区
  • 适配互认证

开发者

开发者相关功能入口汇聚
技术社区
  • 专栏文章
  • 互动问答
  • 技术视频
资源与工具
  • OpenAPI中心
培训与认证
  • 天翼云学堂
  • 天翼云认证
开源社区
  • 魔乐社区
  • OpenTeleDB

支持与服务

为您提供全方位支持与服务,全流程技术保障,助您轻松上云,安全无忧
文档与工具
  • 文档中心
  • 新手上云
  • 自助服务
  • OpenAPI中心
定价
  • 价格计算器
  • 定价策略
基础服务
  • 售前咨询
  • 在线支持
  • 在线支持
  • 工单服务
  • 服务保障
  • 会员中心
增值服务
  • 红心服务
  • 首保服务
  • 客户支持计划
  • 专家技术服务
  • 备案管家
我要反馈
  • 建议与反馈
  • 用户体验官
信息公告
  • 客户公告

了解天翼云

天翼云秉承央企使命,致力于成为数字经济主力军,投身科技强国伟大事业,为用户提供安全、普惠云服务
品牌介绍
  • 关于天翼云
  • 智算云
  • 新闻资讯
  • 天翼云APP
基础设施
  • 全球基础设施
  • 信任中心
最佳实践
  • 精选案例
  • 超级探访
  • 云杂志
  • 分析师和白皮书
  • 天翼云·创新直播间
市场活动
  • 2026智能云生态大会
  • 2025智能云生态大会
  • 2024智算云生态大会
  • 2023云生态大会
  • 2022云生态大会
  • 天翼云中国行
天翼云
  • 活动
  • 息壤智算
  • 产品
  • 解决方案
  • 应用商城
  • 定价
  • 合作伙伴
  • 开发者
  • 支持与服务
  • 了解天翼云
      • 文档
      • 控制中心
      • 备案
      • 管理中心
      云服务总线CSB_相关内容
      • 事件总线事件目标
        您可以通过事件规则过滤事件,将事件路由到同账号下的另一自定义事件总线。本文以自定义事件为例介绍将事件路由到事件总线的前提条件、操作步骤和结果验证。 前提条件 开通事件总线EventBridge并委托授权。 创建自定义总线。 操作步骤 1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。 2. 选择目标总线,点击事件源 按钮,点击添加事件源按钮,创建一个自定义事件源;填写事件源名,事件提供方可选择自定义应用。 3. 在左侧导航栏,单击事件规则 ,然后单击添加事件规则。 4. 在创建规则页面,完成以下操作。 1. 在配置基本信息 配置向导页面中,在名称 文本框输入规则名称,在描述文本框输入规则的描述,然后单击下一步。 2. 在配置事件模式配置向导页面中,在事件模式内容代码框输入事件模式,此处可选择匹配全部事件,然后单击下一步。如需了解更多信息,请参见事件模式。 3. 配置事件目标,事件总线目标参数描述如参数说明所示,然后单击创建。 参数说明 参数 说明 示例 事件总线 选择自定义事件总线 结果验证 1. 触发一次事件,可在对应总线处点击发布事件按钮,生产一个事件。 2. 可在目标事件总线的事件追踪侧查看是否有事件投递。
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件规则
        事件目标
        目标服务类型
        事件总线事件目标
      • 主子账号和IAM权限管理
        功能模块 权限名称 EventBridge admin EventBridge user EventBridge viewer EventBridge publisher 事件 发送事件 √ √ √ 事件总线 创建自定义总线 √ √ 事件总线 删除自定义总线 √ √ 事件总线 查询自定义总线详情 √ √ √ √ 事件总线 查询总线列表 √ √ √ √ 事件规则 创建事件规则 √ √ 事件规则 删除事件规则 √ √ 事件规则 查询事件规则列表 √ √ √ √ 事件规则 查询事件规则详情 √ √ √ √ 事件规则 更新事件规则 √ √ 事件源 查询事件源详情 √ √ √ √ 事件源 创建事件源 √ √ 事件源 删除事件源 √ √ 事件源 查询事件源列表 √ √ √ √ 事件流 创建事件流 √ √ 事件流 查询事件流详情 √ √ √ √ 事件流 删除事件流 √ √ 事件流 查询事件流列表 √ √ √ √ 实例生命周期 开通实例 √ 实例生命周期 退订实例 √ Schema 查询事件Schema列表 √ √ √ √ Schema 查询事件Schema详情 √ √ √ √ 网络管理 查询访问端点列表 √ √ √ √ 事件中心 查看监控报告 √ √ √ √
        来自:
        帮助文档
        事件总线
        产品简介
        主子账号和IAM权限管理
      • 入门流程
        本文带您快速熟悉使用云主机备份(CTCSBS,Cloud Server Backup Service)的操作流程。 以下是云主机备份的基础入门操作流程: 1.注册天翼云帐号,请参考准备工作步骤一。 2.登录并实名认证,请参考准备工作步骤二。 3.账号充值,请参考准备工作步骤三。 4.创建存储库。 5.创建云主机备份。
        来自:
        帮助文档
        云主机备份 CSBS
        快速入门
        入门流程
      • 分布式消息服务RabbitMQ事件源
        本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务RabbitMQ作为事件流中的事件提供方。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 分布式消息服务RabbitMQ 开通分布式消息服务RabbitMQ。 创建所需的vhost和queue。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在事件源(Source)配置 面板,事件提供方 选择分布式消息服务RabbitMQ,选择vhost和queue等配置然后单击确认,如图1所示。 图1 创建事件流时选择分布式消息服务RabbitMQ为事件提供方 参数说明 参数 说明 示例 RabbitMQ实例 选择分布式消息服务RabbitMQ实例。 instancexxx RabbitMQ vhost 选择分布式消息服务RabbitMQ vhost。 / RabbitMQ queue 选择分布式消息服务RabbitMQ queue。 queuexxx 事件示例 plaintext { "id": "b5771f766cdf48edb1bad15418c", "source": "ctyun:rabbitmq", "specversion": "1.0", "subject": "ctyun:rabbitmq:bb9fdb4205xxxxx610242ac110002:16789:queue:topicqueue", "time": "20240305T13:52:18.374Z", "datacontenttype": "application/json;charsetutf8", "type": "ctyun.rabbitmq.topic.sendMessage", "ctyunregion": "bb9fdb4205xxxxx610242ac110002", "ctyunaccountid": "123456789", "data": { "envelope": { "messageId": "xx", "contentEncoding": "UTF8", "contentType": "application/json" }, "body": { "key": "value" }, "props": { "deliveryTag": 98, "exchange": "", "redeliver": false, "routingKey": "housekeeping" } } } data字段包含的参数解释如下表所示: 参数 类型 示例值 描述 props Object 详见props字段参数解释 消息属性,详见props字段参数解释。 envelope Object 详见envelope字段参数解释 消息的envelope信息,详见envelope字段参数解释。 body Object {"key":"value"} 消息体,默认以JSON格式编码。 data 字段下envelope属性包含的参数解释如下表所示: 参数 类型 示例值 描述 deliveryTag Integer 98 消息的Tag。 exchange String / 消息的Exchange。 redeliver Boolean false 是否支持重发消息。取值说明如下: true:支持。 false:不支持。 routingKey String housekeeping 消息的路由规则。 data 字段下props属性包含的参数解释如下表所示: 参数 类型 示例值 描述 contentEncoding String utf8 消息内容编码。 messageId String f7622d51e19841dea07277c1ead7 消息ID。 contentType String application/json 消息contentType。
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件源
        分布式消息服务RabbitMQ事件源
      • 路由到分布式消息服务RocketMQ
        本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务RocketMQ作为事件流中的服务类型。 前提条件 开通事件总线EventBridge并委托授权。 开通分布式消息服务RocketMQ,并创建实例。 创建事件流 1. 登录事件总线EventBridge管理控制台,在左侧导航栏,单击事件流。 2. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击创建。 1. 在Source(源) 、Filtering(过滤) 、Transform(转换)配置向导,设置数据提供方、事件过滤、转换规则,单击下一步。 2. 在Sink(目标) 配置向导,选择服务类型分布式消息服务RocketMQ,配置以下参数,如图1所示。 图1 创建事件流时选择目标服务类型为分布式消息服务RocketMQ 3. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流 页面的状态 栏查看启动进度。 参数说明 参数 说明 示例 实例 选择分布式消息服务RocketMQ实例。 instancexxx Topic 选择RocketMQ实例的Topic。 topic1 消息体 选择消息体(Body)的内容,更多内容请参考事件内容转换。 完整事件 自定义属性 选择自定义属性(Properties)的内容,请参考事件内容转换。 空 索引 选择索引(Keys)的内容,更多的内容,请参考事件内容转换。 空 标签 选择标签(Tags)的内容,更多的内容,请参考事件内容转换。 空
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件目标
        路由到分布式消息服务RocketMQ
      • 管理自定义事件源
        本文介绍如何在事件总线EventBridge管理控制台管理自定义事件源,包括添加、查看和删除自定义事件源。 添加自定义事件源 1. 登录事件总线EventBridge管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称,若无自定义总线,可单击右上角快速创建,以创建一条自定义总线。 4. 在左侧导航栏,单击事件源。 5. 在事件源页面,单击添加事件源。 6. 在添加自定义事件源面板,输入名称 和描述 ,选择事件提供方 ,然后单击确认。 查看自定义事件源 1. 登录事件总线EventBridge管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源页面,找到目标自定义事件源,在其右侧操作列单击详情。 6. 事件源详情页面显示事件源的基本信息和事件源配置信息。 删除自定义事件源 1. 登录事件总线EventBridge管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源页面,找到目标自定义事件源,在其右侧操作列单击删除。 6. 在提示对话框,阅读提示信息,然后单击确认。
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件源
        管理自定义事件源
      • 发布事件
        本文介绍如何通过事件总线EventBridge管理控制台发布事件。您可以通过发布事件测试自定义事件总线配置的事件规则。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权 创建自定义总线 操作步骤 1. 登录事件总线EventBridge管理控制台,在左侧导航栏,单击事件总线。 2. 在事件总线页面,找到目标总线,在其右侧操作列单击发布事件。 3. 在发布事件至自定义事件总线 面板,自定义事件源 下拉列表选择已创建的自定义事件源,在事件体 代码框输入事件内容,然后单击确定 。事件包含的参数规范,请参见事件概述。 注意仅自定义事件总线支持通过管理控制台发布事件。
        来自:
        帮助文档
        事件总线
        用户指南
        事件
        发布事件
      • 共享镜像
        本节介绍了共享镜像的流程等内容。 共享镜像概述 共享镜像是将自己已经创建好的私有镜像共享给其他用户使用。共享后,接受者可以使用该共享镜像快速创建运行同一镜像环境的云主机。 约束与限制 镜像支持共享到对方租户相同区域内。 每个镜像最多可以共享给128个租户,整机镜像最多可以共享给10个租户。 加密镜像不支持共享。 只有通过云服务备份,或者云主机(未通过旧版CSBS服务生成备份)创建的整机镜像,才支持共享。 共享过程 用户A作为共享镜像提供者,用户B作为共享镜像接受者时,用户A将私有镜像共享给用户B的具体流程如下: 1. 用户B提供自己的账号名给用户A。 如果用户B是专属云用户或多项目用户,除提供账号名外,还需要额外提供项目名称。 2. 用户A共享指定的镜像给用户B。 3. 用户B确认接受用户A的共享镜像。 用户B可以使用用户A共享的镜像,完成创建云主机等操作。 相关问题 还有其他关于共享镜像的疑问,请参考镜像共享类。 获取账号名和项目名称 操作场景 用户A将私有镜像共享给用户B之前,用户B将自己的账号名提供给用户A。如果用户B为专属云用户或多项目用户,还需要额外提供项目名称。本节指导用户B获取账号名和项目名称。 操作步骤 1. 用户B登录控制台。 2. 选择“镜像服务”。 进入镜像服务页面。 3. 单击右上角的用户名,选择下拉列表中的“我的凭证”。 在“我的凭证”页面的项目列表中查看账号名和项目名称(即“项目”列取值)。
        来自:
        帮助文档
        镜像服务 IMS
        用户指南
        管理私有镜像
        共享镜像
      • 自定义HTTP/HTTPS事件源
        本文介绍如何在事件总线EventBridge管理控制台中添加HTTP/HTTPS类型的自定义事件源。 前提条件 事件总线EventBridge ++开通事件总线EventBridge并委托授权++。 创建自定义总线。 若使用内网请求地址,需要通过网络端点打通用户vpc到事件总线侧的网络,详见网络端点。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源 页面,单击添加事件源。 6. 在添加自定义事件源 面板,输入名称 和描述 ,事件提供方 选择HTTP/HTTPS触发,配置相关参数,然后单击确认,如图1所示。 7. 图1 创建事件源时事件提供方选择HTTP/HTTPS触发 参数说明 参数 说明 示例 名称 事件源名。 source1 请求类型 支持的请求类型: HTTP HTTPS HTTP&HTTPS HTTPS 请求方法 选择支持的HTTP请求方法。取值如下: GET POST PUT DELETE HEAD PATCH GET 安全配置 选择安全配置的类型。取值如下: 无需配置:不配置,接收到的所有URL请求均转换为事件推送到事件总线EventBridge。 IP网段:输入IP网段。只有使用网段内的IP地址访问的URL才能触发事件,其余请求均会被过滤。 安全域名:输入安全的域名信息。只有使用该域名访问的URL才能触发事件,其余请求均会被过滤。 无需配置
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件源
        自定义事件源类型
        自定义HTTP/HTTPS事件源
      • 使用函数计算作为Transform
        本文介绍使用函数计算作为Transform时的背景信息、注意事项及操作步骤。 背景信息 当Transform选择天翼云函数计算时,您可以通过编写函数代码对事件进行更复杂、更加定制化的处理。整体流程如图所示。 1. 源端(Source)拉取事件后,事件会进入Filter阶段。 2. Filter阶段会事件进行判断,决定是否过滤该事件。经过Filter过滤的事件会进入Transform阶段。 3. Transform会对Filter过滤的事件进一步处理,依次调用函数进行处理。 4. Transform调用完函数之后,会将函数返回的内容推送给目标端(Sink)。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 函数计算 开通函数计算。 已创建对应函数。 操作步骤 1. 登录事件总线EventBridge控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在创建事件流页面,完成以下操作。 1. 在Source(源)配置向导,选择数据提供方及其资源信息,然后单击下一步。更多事件源信息参考事件流事件源。 2. 在Filtering(过滤)配置向导,在事件模式内容代码框输入事件模式,然后单击下一步。 3. 在Transform(转换)配置向导 ,设置事件转换规则,设置选择天翼云服务 为函数计算。 4. 在Sink(目标)配置向导,设置事件目标。更多事件目标信息参考事件流事件目标。 配置方式 参数 说明 绑定现有函数 函数 选择的服务中的函数。 绑定现有函数 版本和别名 选择服务的版本或别名。 5. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件内容转换
        使用函数计算作为Transform
      • 路由到函数计算
        本文介绍如何在事件总线EventBridge管理控制台添加函数计算作为事件流中的服务类型。 前提条件 开通事件总线EventBridge并委托授权。 创建自定义总线服务。 创建函数。 创建事件流 1. 登录事件总线EventBridge管理控制台,在左侧导航栏,单击事件流。 2. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击创建,任务创建详细步骤如下: 1. 在Source(源) 、Filtering(过滤) 、Transform(转换)配置向导,设置数据提供方、事件过滤、转换规则,单击下一步。 2. 在Sink(目标) 配置向导,选择服务类型为函数计算,配置以下参数,详见下方参数说明。 3. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流 页面的状态 栏查看启动进度。 参数说明 参数 说明 示例 函数 选择函数。 funxxx 函数版本或别名 选择函数版本或别名。 版本/LATEST 执行方式 选择执行函数的方式:同步或异步。 同步 事件 选择调用到函数的事件内容,更多内容请参考事件内容转换。 完整事件 结果验证 1. 登录函数计算管理控制台。 2. 在函数页面,单击目标函数名称。 3. 在目标函数详情页面,单击监控页签,可查看函数是否被触发,以及调用时延,如图1所示。 图1 在函数计算管理控制台中查看函数指标
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件目标
        路由到函数计算
      • 典型应用场景
        本文介绍事件总线EventBridge产品中的典型应用场景。 场景一:函数计算触发器 事件总线提供了标准化与中心化的接入方式,支持天翼云应用及自定义应用作为事件源接入。 事件总线EventBridge对事件进行过滤,路由与转换,然后触发事件规则对应的函数,处理对应的业务逻辑。 场景二:多功能数据集成与同步 事件总线EventBridge的事件流模块适用于端到端、实时的过滤与转换流式数据。通过事件流,可轻松实现消息路由与消息同步。 场景三:应用间事件流转 应用产生的事件可以通过事件总线触发,实现应用间的流转,打破应用间的事件孤岛;事件总线EventBridge提供丰富的事件过滤与转换能力。
        来自:
        帮助文档
        事件总线
        产品简介
        典型应用场景
      • 监控指标
        本文介绍如何在事件总线EventBridge控制台如何查询事件总线与事件流的指标监控。 查看事件总线指标 1. 登录事件总线控制台 2. 在左侧导航栏,单击事件中心, 选择指标监控。 3. 在指标监控页面,默认可查看事件总线的监控图表。 4. 可以在页面左上角选择想查看的总线和规则指标监控图标。 查看事件流指标 1. 登录事件总线控制台 2. 在左侧导航栏,单击事件中心, 选择指标监控。 3. 在指标监控页面,左上角切换到事件流,可查看事件流的监控图表。 4. 可以在页面左上角选择想查看的事件流监控图标。 事件总线支持的监控指标 指标名称 指标对象 监控周期 指标描述 指标单位 过滤成功 事件规则 1分钟 单位时间内根据规则过滤条件成功匹配到的事件数量 count 规则推送 事件规则 1分钟 单位时间内成功将事件推送到目标的数量 count 规则推送延迟P99 事件规则 1分钟 单位时间内事件被发送到目标后,目标响应所需的P99时延 ms 总线接入 事件总线 1分钟 单位时间内流入到事件总线中的事件数量 count 事件流入 事件流 1分钟 单位时间内进入事件流的事件数量 count 事件处理 事件流 1分钟 单位时间内成功将事件推送到目标数量 count 事件推送延迟P99 事件流 1分钟 单位时间内事件被发送到目标后,目标响应所需的P99时延 ms
        来自:
        帮助文档
        事件总线
        用户指南
        事件中心
        监控指标
      • 分布式消息服务RocketMQ事件源
        本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务RocketMQ作为事件流中的事件提供方。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 分布式消息服务RocketMQ 开通分布式消息服务RocketMQ并开通实例。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在事件源(Source) 配置面板,事件提供方 选择分布式消息服务RocketMQ,选择或填入主题等配置然后单击确认,如图1所示。 图1 创建事件流时选择分布式消息服务RocketMQ作为事件提供方 参数说明 参数 说明 示例 实例名称 前提条件中已创建的分布式消息服务RocketMQ版实例。 xxx Topic 当前实例中的Topic。 topic1 Group 消费组名。 快速创建:自动创建以GIDEVENTBRIDGExxx命名的Group ID。 使用已有:选择当前实例中已创建的Group,请不要与已有业务的Group混用,以免影响已有的消息收发。 group1 消费位点 开始消费的位置。 最新位点:从最新位点开始消费。 最新位点 Tag 用于过滤消息的Tag值,非必填。 tag1 事件示例 plaintext { "id": "413305a4207647fc94432639472752be", "source": "ctyun:rocketmq", "specversion": "1.0", "subject": "ctyun:rocketmq:bb9fdb42056xxxxxx0242ac110002:dab4124510dd4xxxxxxxxx5c6a6db69:topic:ebsource", "time": "20250205T08:01:47.633357732Z", "datacontenttype": "application/json", "type": "rocketmq:Topic:SendMessage", "ctyunregion": "b342b77efxxxxxxxxxxxxxac110002", "ctyunaccountid": "0b3a63383xxxxxxxxxxxxxxxxx4233ab4da", "data": { "systemProperties": { "MINOFFSET": "0", "MAXOFFSET": "1", "KEYS": "webtest", "CONSUMESTARTTIME": "1738742507633", "CLUSTER": "c967202954xxxxxxxxxxx268bf6222285", "UNIQKEY": "21001CDC0BExxxxxxxxx806D2460082", "TAGS": "17387423002290" }, "userProperties": {}, "topic": "source0205", "msgId": "21001CDC0BE805EF04B51806D2460082", "body": "WebTestTools173874230022xxxxxxxxxxxxxxxxxx5gC7OiRAiPNG1NwCig6Fwd9eS" } } data字段包含的参数解释如下表所示: 参数 类型 示例值 描述 topic String source1 Topic名称。 msgId String 210018FC0EE205EF04B51CF068350066 消息ID。 systemProperties Object 详见systemProperties属性参数解释 消息systemProperties。 userProperties Object {} 消息userProperties。 body Object WebsFjDDxPd503bG60bNdaT0qMrsjt5evXd9df 消息体,默认以JSON格式编码。 data 字段中systemProperties 属性的参数解释如下图所示: 参数 类型 示例值 描述 CLUSTER String 16e0eef12f83485dbba23a0750ec5078 RocketMQ实例集群ID。 CONSUMESTARTTIME String 1733467917369 开始消费时间戳。 KEYS String key 消息Key值。 TAGS String 17334679173510 消息Tag值。 MINOFFSET String 0 最小消费位点。 MAXOFFSET String 1 最大消费位点。
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件源
        分布式消息服务RocketMQ事件源
      • 查询事件轨迹
        本文介绍如何在事件总线EventBridge控制台按事件ID或时间范围查询事件轨迹和事件详情。 约束与限制 事件总线EventBridge仅支持查询72小时内的事件。 每次查询最多返回5000条数据,若数据量过大,请缩小查询时间范围或精确查询条件。 按事件ID查询事件轨迹与事件详情 1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。 2. 选择目标总线,点击事件追踪 按钮,点击按事件ID查询 ;输入事件ID,点击查询。 3. 在下方事件列表中查看事件的ID,事件源,事件类型与事件接收时间等信息。 4. 点击查询事件轨迹,查看事件的事件接收与事件投递详情,详见图1。 5. 点击事件详情,可查看事件的参数详情。 图1 根据时间范围查询事件 按时间范围查询事件轨迹与事件详情 1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。 2. 选择目标总线,点击事件追踪 按钮,点击按时间范围查询 ,配置对应参数,点击查询,详见图2。 1. 时间范围:选择对应时间范围。 2. (可选)事件源:选择已创建的事件源。 3. (可选)事件类型:选择对应事件类型。 3. 在查询的结果列表中找到目标事件,在其右侧操作列,查询事件轨迹和事件详情。 图2 根据事件范围查询事件
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件追踪
        查询事件轨迹
      • 路由到分布式消息服务RabbitMQ
        本文介绍如何在事件总线EventBridge控制台添加分布式消息服务RabbitMQ作为事件流中的服务类型。 前提条件 开通事件总线EventBridge并委托授权。 开通RabbitMQ实例,并创建好相应的交换器、队列。 创建事件流 1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流。 2. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击创建。 1. 在Source(源) 、Filtering(过滤) 、Transform(转换)配置向导,设置数据提供方、事件过滤、转换规则,单击下一步。 2. 在Sink(目标) 配置向导,选择服务类型为分布式消息服务RabbitMQ,配置以下参数,如图1所示。 图1 创建事件流时目标的服务类型选择分布式消息服务RabbitMQ 3. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流 页面的状态 栏查看启动进度。 参数说明 参数 说明 示例 实例 选择分布式消息RabbitMQ实例。 instancexxx Vhost 选择RabbitMQ实例的Vhost。 POST 目标类型 选择发送到RabbitMQ的目标类型。 交换器:通过选择交换器和路由键,事件带上路由键会发送到所选择交换器。 队列:事件会发送到目标队列。 队列 queuexxx 消息体 选择作为消息体的事件内容,更多内容请参考事件内容转换。 完整事件 MessageId 选择MessageId的内容,更多内容请参考事件内容转换。 空 自定义属性 选择自定义属性(Properties)的内容,更多内容请参考事件内容转换。 空
        来自:
        帮助文档
        事件总线
        用户指南
        事件流
        事件目标
        路由到分布式消息服务RabbitMQ
      • 如果只创建自定义事件总线,但无事件投递,会收费吗?
        不会。事件总线采取按量计费的方式,创建自定义事件总线本身不付费。只有投递的事件进入自定义事件总线,才会产生费用。
        来自:
        帮助文档
        事件总线
        常见问题
        计费类
        如果只创建自定义事件总线,但无事件投递,会收费吗?
      • 故障恢复
        本文带您了解故障恢复相关产品。 您可以通过天翼云云主机备份产品和云硬盘备份产品,对弹性云主机上的数据进行备份,当云主机或主机上的云硬盘出现故障,或者软件造成的数据丢失损坏以及人为错误导致的数据误删时,您可以借助备份功能自助快速恢复数据。 云主机备份 云主机备份(CTCSBS,Cloud Server Backup Service)提供对弹性云主机的备份保护服务,支持基于云硬盘快照技术的备份服务,并支持利用备份数据恢复弹性云主机数据。通过云主机备份服务,可以在发生数据丢失、系统故障、人为错误或恶意攻击等情况下,还原云主机数据,确保业务的连续性和数据的安全性。 更多内容请参见云主机备份。 云硬盘备份 云硬盘备份(CTVBS,Volume Backup Service)是针对云主机的系统盘、数据盘提供的备份服务。用户可对存储重要数据的云硬盘进行备份,并在云硬盘故障、用户误删数据、遭到黑客攻击等情况下,使用备份快速恢复数据,最大限度保证用户数据的安全性。 更多内容请参见云硬盘备份。 云主机备份和云硬盘备份的差异 产品名称 备份对象 产品要点说明 场景说明 云主机备份 云主机 整机备份,通过存储快照技术,将云主机包含的多个云硬盘的数据备份到对象存储。 周期备份、手动备份。 支持恢复原云主机或创建新的云主机。 针对需要对整个云主机进行保护,或者希望通过备份创建云主机达到快速复制业务运行环境的场景,建议使用云主机备份。 云硬盘备份 云硬盘 通过存储快照技术,将云硬盘数据备份到对象存储。 周期备份、手动备份。 支持恢复原云硬盘,和使用备份数据创建新的云硬盘。 针对系统盘没有自定义数据的场景,可以选择使用云硬盘备份对系统盘和数据盘进行备份,保证数据安全的同时,降低备份成本。
        来自:
        帮助文档
        弹性云主机 ECS
        用户指南
        安全
        故障恢复
      • 对象存储触发器
        对象存储与函数计算集成后,对象存储事件能触发相关工作流执行,实现对对象存储中的数据的自定义处理。 背景信息 对象存储和工作流通过对象存储触发器实现无缝集成,可以编排工作流对对象存储事件进行自定义处理,当对象存储捕获到指定类型的事件后,对象存储事件触发相应的工作流执行。例如,可以设置工作流来处理PutObject事件,当上传图片到对象存储后,相关联的工作流会自动被触发来处理该图片。 对象存储和工作流集成后,可以自由地调用各种工作流处理图像或音频数据,再把结果写回到多种存储服务中。整个架构中,只需要专注于工作流逻辑的编写,系统将以实时的、可靠的、大规模并行的方式处理海量的数据。 前提条件 创建事件总线类触发器前,需要先确认开通事件总线对工作流的服务委托,赋予事件总线调用工作流的权限。 对象存储事件定义 当对象存储系统捕获到相关事件后,会将事件信息编码为JSON字符串,传递给事件处理函数。 已支持的对象存储事件定义如下表所示。 事件类型 说明 s3:ObjectCreated:Put 原子上传对象到Bucket。 s3:ObjectCreated:Post Post上传对象到Bucket。 s3:ObjectCreated:CompleteMultipartUpload 分段上传对象到Bucket。 s3:ObjectCreated:Copy 拷贝上传。 s3:ObjectRemoved:Delete 删除Bucket中对象。 s3:ObjectRemoved:DeleteMarkerCreated 不指定版本号删除多版本Bucket中对象。 s3:ObjectRestore:Post 对象解冻。
        来自:
        帮助文档
        函数计算
        用户指南
        云工作流
        控制台操作
        工作流调度
        事件总线类触发器
        对象存储触发器
      • 基于事件流实现Kafka消息路由
        本文介绍如何应用事件总线EventBridge的事件流功能实现分布式消息服务Kafka的消息路由。 前提条件 开通事件总线EventBridge并授权。 开通分布式消息服务Kafka并创建最少两个主题。 背景信息 事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务Kafka生产的消息可以通过事件流这个通道被路由到目标端的分布式消息服务Kafka。 步骤一:创建事件流 1. 登录事件总线EventBridge控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击保存。 a.在Source(源)配置向导,选择数据提供方为分布式消息服务Kafka ,设置以下参数,然后单击下一步。 参数 说明 示例 Kafka实例 选择Kafka实例。 instancexxx Kafka Topic 选择Kafka topic。 topicxxx Group 选择消费组。 快速创建 消费位点 选择消费位点。 最新位点 b.在Filtering(过滤)配置向导,设置事件过滤规则,单击下一步。 c.在Sink(目标)配置向导,选择服务类型为分布式消息服务Kafka,配置参数,单击保存,如图1所示。 参数 说明 示例 Kafka实例 选择Kafka实例。 instancexxx Kafka Topic 选择Kafka topic。 topicxxx 消息体(value) 提取事件中的数据。 $.data.value 消息键值(key) 提前事件中的key到目标。 $.data.key 图1 创建事件流时目标类型选择分布式消息服务Kafka 5. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现Kafka消息路由
      • SDK概述
        本文主要介绍事件总线EventBridge提供的开源CloudEvents SDK示例,以简化您的开发工作。 前提条件 若想使用开源CloudEvents SDK示例,需提前准备以下信息: 天翼云账号的aksk,确保该账号已授权事件总线的发布权限,详见主子账号和IAM权限管理。 需要发送事件的对应自定义事件总线,可在事件总线EventBridge管理控制台中查看事件总线列表。 发送SDK的接入点地址,可在事件总线EventBridge管理控制台中点击对应事件总线,进入概览页,在接入点一栏中得到。 确认事件格式。详见事件概述,若事件格式不符合CloudEvents 1.0协议,会导致事件发送失败。 若使用内网域名接入,请确保内网域名已添加访问端点,详见创建私网访问端点。 发送事件 使用CloudEvents SDK发送事件,请参见各语言版本的SDK示例。
        来自:
        帮助文档
        事件总线
        开发参考
        SDK概述
      • 自定义自建Apache RocketMQ事件源
        本文介绍如何在事件总线EventBridge管理控制台中添加自建Apache RocketMQ类型的自定义事件源。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 创建自定义总线。 您已部署Apache RocketMQ集群,并在您的天翼云VPC内或公共网络可访问集群接入点。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源 页面,单击添加事件源。 6. 在添加自定义事件源 面板,输入名称 和描述 ,事件提供方 选择自建Apache RocketMQ,配置相关参数,然后单击确认,如图1所示。 图1 创建事件源时事件提供方选择自建Apache RocketMQ 参数说明 参数 说明 示例 名称 事件源名。 source1 接入点 Apache RocketMQ集群broker接入点,由IP与端口号拼接而成,以逗号分隔。 172.17.0.25:9876,192.17.0.26:9876,172.17.0.27:9876 Topic topic名称。 topic1 Group ID 填入当前Apache Kafka集群中已创建的Group,请不要与已有业务的Group混用,以免影响已有的消息收发。 group1 Tag 用于消息过滤的Tag,非必填。 tag 网络配置 根据业务场景选择对应配置。 专有网络 公网网络 专有网络 VPC 网络配置选择专有网络时必填,选择集群所在的VPC。 vpc 子网 网络配置选择专有网络时必填,选择集群所在的子网。 subnet 认证模式 选择认证模式。 无需配置 ACL 用户名:填写用户名 密码:填写密码 无需配置 消费位点 消费消息的位点。 最早位点 最早位点 数据格式 消息value数据编码格式。 JSON Text Binary JSON
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件源
        自定义事件源类型
        自定义自建Apache RocketMQ事件源
      • 产品优势
        本文介绍事件总线EventBridge的产品优势。 可用性 支持高吞吐量的事件发布和消费。 支持服务Serverless化和自动弹性伸缩,轻松应对突发流量。 支持无状态实例,节点异常对服务无影响,服务可用性高。 易用性 支持无缝迁移上云,完全兼容CloudEvents 1.0。 支持多种访问方式,包括控制台与CloudEvents SDK。 支持接入多种应用程序,包括天翼云服务和自定义应用。 安全性 对接统一身份认证服务,支持通过天翼云账号向RAM用户授权。 支持HTTP/HTTPS协议。
        来自:
        帮助文档
        事件总线
        产品简介
        产品优势
      • 自定义事件源定时触发
        本文介绍如何在事件总线EventBridge管理控制台中添加定时触发类型的自定义事件源。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 创建自定义总线。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源 页面,单击添加事件源。 6. 在添加自定义事件源 面板,输入名称 和描述 ,事件提供方 选择定时触发,配置触发周期等配置,然后单击确认,如图1所示。 图1 创建事件源时事件提供方选择定时触发 参数说明 参数 说明 示例 名称 事件源名。 source1 触发周期 选择固定周期 或自定义Cron。 固定周期 固定周期 设置固定周期的时间。当触发周期配置为固定周期时,需配置此参数。 30秒 Cron表达式 当触发周期配置为自定义Cron时,需配置此参数。请输入秒级Cron表达式。 Cron表达式示例如下: /10 :每10秒触发 0 :每分钟的第0秒触发 Cron执行时区 当触发周期配置为自定义 Cron时,需配置此参数。选择触发周期执行的时区,默认为UTC时区。 UTC时区
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件源
        自定义事件源类型
        自定义事件源定时触发
      • 如何将事件内容转换后传输到事件目标?
        事件总线EventBridge支持事件内容转换,即将事件源发出的符合CloudEvents 1.0协议的事件转换为事件目标可以接收的格式。 事件总线EventBridge支持的事件内容转换类型如下: 完整事件:事件总线EventBridge不对事件进行转换,将事件的完整结构路由到事件目标。 部分事件:事件总线EventBridge通过JSONPath从符合CloudEvents格式的事件中提取事件中的参数,将指定的事件内容路由到事件目标。 固定值:事件只起到触发器的作用,不管事件内容是什么,事件总线EventBridge都把常量路由到事件目标。 模板:当转换类型为模板时,通过自定义模板、定义模板里需要的变量,事件总线EventBridge通过JSONPath从事件中提取参数,把这些值存放在变量中,然后按照模板定义的格式路由到事件目标。 更多信息,请参照事件内容转换。
        来自:
        帮助文档
        事件总线
        常见问题
        通用类
        如何将事件内容转换后传输到事件目标?
      • 函数计算事件目标
        您可以通过事件规则过滤事件,将事件路由到函数计算。本文以自定义事件为例介绍将事件路由到函数计算的前提条件、操作步骤和结果验证。 前提条件 开通事件总线EventBridge并委托授权。 创建自定义总线。 开通函数计算、创建函数。 操作步骤 1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。 2. 选择目标总线,点击事件源 按钮,点击添加事件源按钮,创建一个自定义事件源;填写事件源名,事件提供方可选择自定义应用。 3. 在左侧导航栏,单击事件规则 ,然后单击添加事件规则。 4. 在创建规则页面,完成以下操作。 1. 在配置基本信息 配置向导页面中,在名称 文本框输入规则名称,在描述文本框输入规则的描述,然后单击下一步。 2. 在配置事件模式配置向导页面中,在事件模式内容代码框输入事件模式,此处可选择匹配全部事件,然后单击下一步。如需了解更多信息,请参见事件模式。 3. 配置事件目标,函数计算目标参数描述如参数说明所示,然后单击创建,如图1所示。 图1 创建事件规则时选择服务类型为函数计算 参数说明 参数 说明 示例 函数 选择函数。 funxxx 函数版本与别名 支持指定函数版本或指定函数别名: 如果您选择指定版本,需要选择函数的具体版本。 如果您选择指定别名,需要选择函数的具体别名。 LATEST 执行方式 选择执行函数的方式:同步或异步。 同步 事件 选择调用到函数的事件内容,更多请参考事件内容转换。 完整事件
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件规则
        事件目标
        目标服务类型
        函数计算事件目标
      • Java SDK
        您可使用开源CloudEvents Java SDK发布事件。 前提条件 1.您已下载IntelliJ IDEA等Java研发IDE。 2.在pom.xml中加入依赖。 plaintext io.cloudevents cloudeventscore ${cloudevents.version} io.cloudevents cloudeventshttpvertx ${cloudevents.version} io.cloudevents cloudeventsapi ${cloudevents.version} io.cloudevents cloudeventsjsonjackson ${cloudevents.version} 注:cloudevents.version使用最新里程碑版本2.0.0milestone1。 发布事件 结构化示例代码如下: java import java.net.URI; import java.util.UUID; import io.cloudevents.CloudEvent; import io.cloudevents.core.builder.CloudEventBuilder; import io.cloudevents.http.vertx.VertxMessageFactory; import io.cloudevents.jackson.JsonFormat; import io.vertx.core.Vertx; import io.vertx.core.http.HttpClient; import io.vertx.core.http.HttpClientRequest; public class SampleStructuredHTTPClient { // 填写天翼云账号的aksk,确保该账号已授权事件总线的发布权限 private static String accessKeyId System.getenv("CTYUNACCESSKEYID"); private static String accessKeySecret System.getenv("CTYUNACCESSKEYSECRET"); // 在事件总线控制台获取服务接入地址 private static String endpoint " + System.getenv("CTYUNEVENTBRIDGESERVICEHOST") + "/api/v1/putEvents"; public static void main(String[] args) throws Exception { final Vertx vertx Vertx.vertx(); final HttpClient httpClient vertx.createHttpClient(); // 创建一个事件模板来设置基本的CloudEvent属性。 CloudEventBuilder eventTemplate CloudEventBuilder.v1() .withSource(URI.create(" .withType("vertx.example"); // 创建HTTP请求。 final HttpClientRequest request httpClient.postAbs(endpoint) .handler(response > { System.out.println(response.statusMessage()); }) .exceptionHandler(System.err::println); String id UUID.randomUUID() .toString(); String data "{"name":"Eventbridge","number":100}"; // 从模板中创建事件。 final CloudEvent event eventTemplate.newBuilder() .withId(id) .withData("application/json", data.getBytes()) // 确保总线已经创建 .withExtension("ctyuneventbusname", "mybus") .withSource(URI.create(" .withType("vertx.example") .withSubject("ceb:cos:huadong1:1234567:events") .build(); request.putHeader("contenttype", "application/cloudevents+json"); request.putHeader("authorization", "ceb" + ":" + accessKeyId + ":" + SignatureHelper.getSignature(SignatureHelper.getStringToSign(request), accessKeySecret) + ""); VertxMessageFactory.createWriter(request) .writeStructured(event, new JsonFormat()); } } 二进制示例代码如下: java import java.net.URI; import java.util.UUID; import io.cloudevents.CloudEvent; import io.cloudevents.core.builder.CloudEventBuilder; import io.cloudevents.http.vertx.VertxMessageFactory; import io.vertx.core.Vertx; import io.vertx.core.http.HttpClient; import io.vertx.core.http.HttpClientRequest; public class SampleBinaryHTTPClient{ // 填写天翼云账号的aksk,确保该账号已授权事件总线的发布权限 private static String accessKeyId System.getenv("CTYUNACCESSKEYID"); private static String accessKeySecret System.getenv("CTYUNACCESSKEYSECRET"); // 在事件总线控制台获取服务接入地址 private static String endpoint " + System.getenv("CTYUNEVENTBRIDGESERVICEHOST"); + "/api/v1/putEvents"; public static void main(String[] args) throws Exception { final Vertx vertx Vertx.vertx(); final HttpClient httpClient vertx.createHttpClient(); // 创建一个事件模板来设置基本的CloudEvent属性。 CloudEventBuilder eventTemplate CloudEventBuilder.v1() .withSource(URI.create(" .withType("vertx.example"); // 创建HTTP请求。 final HttpClientRequest request httpClient.postAbs(endpoint) .handler(response > { System.out.println(response.toString()); }) .exceptionHandler(e > { System.out.println(e); }); String id UUID.randomUUID() .toString(); String data "{"name":"Eventbridge","number":100}"; // 从模板中创建事件。 final CloudEvent event eventTemplate.newBuilder() .withId(id) .withData("application/json", data.getBytes()) // 确保总线已经创建 .withExtension("ctyuneventbusname", "mybus") .withSource(URI.create(" .withType("vertx.example") .withSubject("ceb:myapp:huadong1:1234567:events") .build(); request.putHeader("contenttype", "application/json"); request.putHeader("authorization", "ceb" + ":" + accessKeyId + ":" + SignatureHelper.getSignature(SignatureHelper.getStringToSign(request), accessKeySecret) + ""); VertxMessageFactory.createWriter(request) .writeBinary(event); } }
        来自:
        帮助文档
        事件总线
        开发参考
        Cloudevents SDK参考
        Java SDK
      • 基于事件流实现消息路由至函数计算
        本文介绍如何应用事件总线EventBridge的事件流功能实现消息路由至函数计算。 前提条件 开通事件总线EventBridge并授权。 开通函数计算并创建对应函数。 开通分布式消息服务Kafka并创建最少两个主题。 背景信息 事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务Kafka生产的消息可以通过事件流这个通道被路由到目标端的函数计算,并触发函数。 步骤一:创建事件流 1. 登录事件总线EventBridge控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击保存。 a.在Source(源)配置向导,选择数据提供方为分布式消息服务Kafka ,设置以下参数,然后单击下一步。 参数 说明 示例 Kafka实例 选择Kafka实例。 instancexxx Kafka Topic 选择Kafka topic。 topicxxx Group 选择消费组。 快速创建 消费位点 选择消费位点。 最新位点 b.在Filtering(过滤)配置向导,设置事件过滤规则,单击下一步。 c.在Sink(目标)配置向导,选择服务类型为函数计算,配置以下参数,单击保存。 参数 说明 示例 函数 选择函数。 funxxx 函数版本或别名 选择函数版本或别名。 版本/LATEST 执行方式 选择执行函数的方式:同步或异步。 同步 事件 选择调用到函数的事件内容,更多内容请参考事件内容转换。 完整事件 5. 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现消息路由至函数计算
      • 基于事件流实现RabbitMQ消息路由
        本文介绍如何应用事件总线EventBridge的事件流功能实现分布式消息服务RabbitMQ的消息路由。 前提条件 开通事件总线EventBridge并授权。 开通分布式消息服务RabbitMQ并开通实例。 背景信息 事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务RabbitMQ生产的消息可以通过事件流这个通道被路由到目标端的分布式消息服务RabbitMQ。 步骤一:创建事件流 1. 登录事件总线EventBridge控制台。 2. 在左侧导航栏,单击事件流。 3. 在事件流页面,单击创建事件流。 4. 在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击保存。 a.在Source(源) 配置向导,选择数据提供方为分布式消息服务RabbitMQ,设置以下参数,然后单击下一步。 参数 说明 示例 RabbitMQ实例 选择分布式消息服务RabbitMQ实例。 instancexxx RabbitMQ vhost 选择分布式消息服务RabbitMQ vhost。 / RabbitMQ queue 选择分布式消息服务RabbitMQ queue。 queuexxx b.在Filtering(过滤)配置向导,设置事件过滤规则,单击下一步。 c.在Sink(目标) 配置向导,选择服务类型为分布式消息服务RabbitMQ,配置以下参数,单击保存,如图1所示。 图1 创建事件流时源的类型选择分布式消息服务RabbitMQ 参数 说明 示例 实例 选择分布式消息RabbitMQ实例。 instancexxx Vhost 选择RabbitMQ实例的Vhost。 POST 目标类型 选择发送到RabbitMQ的目标类型。 1. 交换器:通过选择交换器和路由键,事件带上路由键会发送到所选择交换器。 2. 队列:事件会发送到目标队列。 队列 queuexxx 消息体 选择作为消息体的事件内容,更多参考“事件内容转换”。 完整事件 MessageId 选择MessageId的内容,更多参考“事件内容转换”。 空 自定义属性 选择自定义属性(Properties)的内容,更多参考“事件内容转换”。 空 创建事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现RabbitMQ消息路由
      • 事件目标概述
        事件目标是事件规则的一部分,负责消费经事件规则过滤与转换后的事件。 事件目标 事件总线EventBridge支持以下事件目标: 函数计算 分布式消息服务RocketMQ 分布式消息服务RabbitMQ 分布式消息服务Kafka HTTP、HTTPS地址
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件规则
        事件目标
        事件目标概述
      • 管理事件规则
        事件规则用于监控特定类型的事件。当发生与事件规则相匹配的事件时,事件会被路由到与事件规则关联的目标。事件规则可以与一个或多个目标关联。本文介绍如何在事件总线EventBridge管理控制台管理事件规则,包括创建、查看和删除事件规则等操作。 前提条件 开通事件总线EventBridge并委托授权。 创建规则 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件规则。 5. 在事件规则 页面,单击创建规则。 6. 在创建规则页面,完成以下操作。 1. 在配置基本信息 配置向导,在名称 文本框输入规则名称,在描述 文本框输入规则的描述,然后单击下一步。 2. 在配置事件模式 配置向导,完成对应配置,然后单击下一步。 3. 在配置事件目标 配置向导,配置事件目标,然后单击创建。 注意 1个事件规则最多可以添加5个事件目标。 查看规则 在事件规则 页面,找到目标事件规则,在其右侧操作 列单击详情。 在规则详情页面查看规则的基础信息、事件模式和事件目标。 禁用规则 在事件规则 页面,找到目标事件规则,在其右侧操作 列选择更多 > 禁用。 启用规则 在事件规则 页面,找到目标事件规则,在其右侧操作 列选择更多 > 启用。 编辑事件目标 1. 在事件规则 页面,找到目标事件规则,在其右侧操作 列单击编辑事件目标。 2. 在编辑规则 页面,修改事件目标配置,然后单击确认。
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件规则
        管理事件规则
      • 自定义自建Apache Kafka事件源
        本文介绍如何在事件总线EventBridge管理控制台中添加自建Apache Kafka类型的自定义事件源。 前提条件 事件总线EventBridge 开通事件总线EventBridge并委托授权。 创建自定义总线。 您已部署Apache Kafka集群,并在您的天翼云VPC内或公共网络可访问集群接入点。 操作步骤 1. 登录事件总线管理控制台。 2. 在左侧导航栏,单击事件总线。 3. 在事件总线页面,单击目标总线名称。 4. 在左侧导航栏,单击事件源。 5. 在事件源 页面,单击添加事件源。 6. 在添加自定义事件源 面板,输入名称 和描述 ,事件提供方 选择自建Apache Kafka,配置相关参数,然后单击确认,如图1所示。 图1 创建事件源时事件提供方选择自建Apache Kafka 参数说明 参数 说明 示例 名称 事件源名。 source1 接入点 Apache Kafka集群broker接入点,由IP与端口号拼接而成,以逗号分隔。 172.17.0.25:9092,192.17.0.26:9092,172.17.0.27:9092 Topic topic名称。 topic1 Group ID 填入当前Apache Kafka集群中已创建的Group,请不要与已有业务的Group混用,以免影响已有的消息收发。 group1 网络配置 根据业务场景选择对应配置。 专有网络 公网网络 专有网络 VPC 网络配置选择专有网络时必填,选择集群所在的VPC。 vpc 子网 网络配置选择专有网络时必填,选择集群所在的子网。 subnet 认证模式 选择认证模式。 PLAINTEXT SASLPLAINTEXT 用户名:填写SASL用户名 密码:填写SASL密码 SASL鉴权方式:可选PLAIN和SCRAMSHA512 PLAINTEXT 消费位点 消费消息的位点。 最新位点 最早位点 最新位点 数据格式 消息value数据编码格式。 JSON Text Binary JSON
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件源
        自定义事件源类型
        自定义自建Apache Kafka事件源
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • ...
      • 641
      跳转至
      推荐热词
      天翼云运维管理审计系统天翼云云服务平台云服务备份云日志服务应用运维管理云手机云电脑天翼云云hbase数据库电信云大数据saas服务电信云大数据paas服务轻量型云主机天翼云客户服务电话应用编排服务天翼云云安全解决方案云服务总线CSB天翼云服务器配置天翼云联邦学习产品天翼云云安全天翼云企业上云解决方案天翼云产品天翼云视频云存储

      天翼云最新活动

      818 天翼云云智盛典

      爆款云主机低至1.5折起,Token套餐低至9.9元/月起

      安全隔离版OpenClaw

      OpenClaw云服务器专属“龙虾“套餐低至1.5折起

      聚力AI赋能 天翼云大模型专项

      大模型特惠专区·Token Plan 轻享包低至9.9元起

      青云志云端助力计划

      一站式科研助手,海外资源安全访问平台,助力青年翼展宏图,平步青云

      企业出海解决方案

      助力您的业务扬帆出海,通达全球!

      天翼云信创专区

      “一云多芯、一云多态”,国产化软件全面适配,国产操作系统及硬件芯片支持丰富

      云上钜惠

      爆款云主机全场特惠,2核4G只要1.8折起!

      天翼云奖励推广计划

      加入成为云推官,推荐新用户注册下单得现金奖励

      产品推荐

      弹性云主机 ECS

      物理机 DPS

      GPU云主机

      多活容灾服务 MDR

      弹性伸缩服务 AS

      弹性高性能计算 E-HPC

      天翼云CTyunOS系统

      AI Store

      科研助手

      推荐文档

      Redis集群管理

      价格

      常见问题

      • 7*24小时售后
      • 无忧退款
      • 免费备案
      • 专家服务
      售前咨询热线
      400-810-9889转1
      关注天翼云
      • 旗舰店
      • 天翼云APP
      • 天翼云微信公众号
      服务与支持
      • 备案中心
      • 售前咨询
      • 智能客服
      • 自助服务
      • 工单管理
      • 客户公告
      • 涉诈举报
      账户管理
      • 管理中心
      • 订单管理
      • 余额管理
      • 发票管理
      • 充值汇款
      • 续费管理
      快速入口
      • 天翼云旗舰店
      • 文档中心
      • 最新活动
      • 免费试用
      • 信任中心
      • 天翼云学堂
      云网生态
      • 甄选商城
      • 渠道合作
      • 云市场合作
      了解天翼云
      • 关于天翼云
      • 天翼云APP
      • 服务案例
      • 新闻资讯
      • 联系我们
      热门产品
      • 云电脑
      • 弹性云主机
      • 云电脑政企版
      • 天翼云手机
      • 云数据库
      • 对象存储
      • 云硬盘
      • Web应用防火墙
      • 息壤智算平台
      • CDN加速
      热门推荐
      • 云服务备份
      • 边缘安全加速平台
      • 全站加速
      • 安全加速
      • 云服务器
      • 云主机
      • 智能边缘云
      • 应用编排服务
      • 微服务引擎
      • 共享流量包
      更多推荐
      • web应用防火墙
      • 密钥管理
      • 等保咨询
      • 安全专区
      • 应用运维管理
      • 云日志服务
      • 文档数据库服务
      • 云搜索服务
      • 数据湖探索
      • 数据仓库服务
      友情链接
      • 中国电信集团
      • 天翼云国际站
      • 189邮箱
      • 天翼企业云盘
      • 天翼云盘
      ©2026 天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
      公司地址:北京市东城区青龙胡同甲1号、3号2幢2层205-32室
      • 用户协议
      • 隐私政策
      • 个人信息保护
      • 法律声明
      备案 京公网安备11010802043424号 京ICP备 2021034386号