本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务Kafka作为事件流中的事件目标。 前提条件 开通事件总线EventBridge并委托授权。 开通分布式消息服务Kafka并创建实例，并创建对应的主题。 创建事件流 1. 登录事件总线EventBridge管理控制台，在左侧导航栏，单击事件流。 2. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击创建，如图1所示。 1. 在Source（源） 、Filtering（过滤） 、Transform（转换）配置向导，设置事件提供方、事件过滤、转换规则，单击下一步。 2. 在Sink（目标） 配置向导，选择服务类型分布式消息服务Kafka，配置参数，详见下方参数说明。 3. 创建事件流后，会有30秒~60秒的延迟时间，您可以在事件流 页面的状态 栏查看启动进度。 图1 创建事件流中选择分布式消息服务Kafka为服务类型 参数说明 参数 说明 示例 实例 选择分布式消息服务Kafka实例。 instancexxx Topic 选择分布式消息服务Kafka实例的Topic。 topic1 消息体 选择消息体（Body）的内容，更多内容请参考事件内容转换。 部分事件 plaintext $.data.value 消息键值 选择消息键值（Key）的内容，更多内容请参考事件内容转换。 部分事件 plaintext $.data.value

您可以通过事件规则过滤事件，将事件路由到自建Apache RocketMQ服务。本文以自定义事件为例介绍将事件路由到自建Apache RocketMQ的前提条件、操作步骤和结果验证。 前提条件 开通事件总线EventBridge并委托授权 创建自定义总线服务 操作步骤 1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件总线。 2. 选择目标总线，在左侧导航栏，单击事件规则，然后单击添加事件规则。 3. 在添加事件规则页面，完成以下操作。 1. 在配置基本信息配置向导，在名称文本框输入规则名称，在描述文本框输入规则的描述，然后单击下一步。 2. 在配置事件模式配置向导，选择匹配全部事件，然后单击下一步。 3. 在配置事件目标 配置向导，配置事件目标，事件目标服务类型选择自建Apache RocketMQ，目标参数描述如下，然后单击创建。 参数说明 参数 说明 示例 接入点 Apache RocketMQ集群broker接入点，由IP与端口号拼接而成，以逗号分隔。 172.17.0.25:9876,192.17.0.26:9876,172.17.0.27:9876 Topic topic名称。 topic1 网络配置 根据业务场景选择对应配置。 专有网络 公网网络 专有网络 VPC 网络配置选择专有网络时必填，选择集群所在的VPC。 vpc 子网 网络配置选择专有网络时必填，选择集群所在的子网。 subnet 认证模式 选择认证模式。 无需配置 ACL 用户名：填写用户名 密码：填写密码 无需配置 消息体 选择消息体（Body）的内容，更多内容请参考事件内容转换。 全部事件 自定义属性 选择自定义属性（Properties）的内容，更多内容请参考事件内容转换。 空 索引 选择索引（Keys）的内容，更多内容请参考事件内容转换。 空 标签 选择标签（Tags）的内容，更多内容请参考事件内容转换。 空

本文介绍如何在事件总线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。

本文介绍如何在事件总线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才能触发事件，其余请求均会被过滤。 无需配置

本文介绍如何在事件总线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

本文介绍如何在事件总线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）的内容，更多的内容，请参考事件内容转换。 空

本节介绍了共享镜像的流程等内容。 共享镜像概述 共享镜像是将自己已经创建好的私有镜像共享给其他用户使用。共享后，接受者可以使用该共享镜像快速创建运行同一镜像环境的云主机。 约束与限制 镜像支持共享到对方租户相同区域内。 每个镜像最多可以共享给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. 单击右上角的用户名，选择下拉列表中的“我的凭证”。 在“我的凭证”页面的项目列表中查看账号名和项目名称（即“项目”列取值）。

本文介绍如何在事件总线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提供丰富的事件过滤与转换能力。

本文带您了解故障恢复相关产品。 您可以通过天翼云云主机备份产品和云硬盘备份产品，对弹性云主机上的数据进行备份，当云主机或主机上的云硬盘出现故障，或者软件造成的数据丢失损坏以及人为错误导致的数据误删时，您可以借助备份功能自助快速恢复数据。 云主机备份 云主机备份（CTCSBS，Cloud Server Backup Service）提供对弹性云主机的备份保护服务，支持基于云硬盘快照技术的备份服务，并支持利用备份数据恢复弹性云主机数据。通过云主机备份服务，可以在发生数据丢失、系统故障、人为错误或恶意攻击等情况下，还原云主机数据，确保业务的连续性和数据的安全性。 更多内容请参见云主机备份。 云硬盘备份 云硬盘备份（CTVBS，Volume Backup Service）是针对云主机的系统盘、数据盘提供的备份服务。用户可对存储重要数据的云硬盘进行备份，并在云硬盘故障、用户误删数据、遭到黑客攻击等情况下，使用备份快速恢复数据，最大限度保证用户数据的安全性。 更多内容请参见云硬盘备份。 云主机备份和云硬盘备份的差异 产品名称 备份对象 产品要点说明 场景说明 云主机备份 云主机 整机备份，通过存储快照技术，将云主机包含的多个云硬盘的数据备份到对象存储。 周期备份、手动备份。 支持恢复原云主机或创建新的云主机。 针对需要对整个云主机进行保护，或者希望通过备份创建云主机达到快速复制业务运行环境的场景，建议使用云主机备份。 云硬盘备份 云硬盘 通过存储快照技术，将云硬盘数据备份到对象存储。 周期备份、手动备份。 支持恢复原云硬盘，和使用备份数据创建新的云硬盘。 针对系统盘没有自定义数据的场景，可以选择使用云硬盘备份对系统盘和数据盘进行备份，保证数据安全的同时，降低备份成本。

本文介绍如何在事件总线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 根据事件范围查询事件

不会。事件总线采取按量计费的方式，创建自定义事件总线本身不付费。只有投递的事件进入自定义事件总线，才会产生费用。

本文主要介绍事件总线EventBridge提供的开源CloudEvents SDK示例，以简化您的开发工作。 前提条件 若想使用开源CloudEvents SDK示例，需提前准备以下信息： 天翼云账号的aksk，确保该账号已授权事件总线的发布权限，详见主子账号和IAM权限管理。 需要发送事件的对应自定义事件总线，可在事件总线EventBridge管理控制台中查看事件总线列表。 发送SDK的接入点地址，可在事件总线EventBridge管理控制台中点击对应事件总线，进入概览页，在接入点一栏中得到。 确认事件格式。详见事件概述，若事件格式不符合CloudEvents 1.0协议，会导致事件发送失败。 若使用内网域名接入，请确保内网域名已添加访问端点，详见创建私网访问端点。 发送事件 使用CloudEvents SDK发送事件，请参见各语言版本的SDK示例。

本文介绍使用函数计算作为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秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

事件总线EventBridge支持事件内容转换，即将事件源发出的符合CloudEvents 1.0协议的事件转换为事件目标可以接收的格式。 事件总线EventBridge支持的事件内容转换类型如下： 完整事件：事件总线EventBridge不对事件进行转换，将事件的完整结构路由到事件目标。 部分事件：事件总线EventBridge通过JSONPath从符合CloudEvents格式的事件中提取事件中的参数，将指定的事件内容路由到事件目标。 固定值：事件只起到触发器的作用，不管事件内容是什么，事件总线EventBridge都把常量路由到事件目标。 模板：当转换类型为模板时，通过自定义模板、定义模板里需要的变量，事件总线EventBridge通过JSONPath从事件中提取参数，把这些值存放在变量中，然后按照模板定义的格式路由到事件目标。 更多信息，请参照事件内容转换。

本文介绍如何在事件总线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控制台添加分布式消息服务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）的内容，更多内容请参考事件内容转换。 空

本文介绍如何在事件总线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 最大消费位点。

本文介绍如何在事件总线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

本文介绍如何应用事件总线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秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

本文带您了解什么是云主机备份产品。 云主机备份（CTCSBS，Cloud Server Backup Service）提供对弹性云主机的备份保护服务，支持基于云硬盘快照技术的备份服务，并支持利用备份数据恢复弹性云主机数据。通过云主机备份服务，可以在发生数据丢失、系统故障、人为错误或恶意攻击等情况下，还原云主机数据，确保业务的连续性和数据的安全性。 备份机制 首次备份为全量备份，备份云主机挂载的全部云硬盘的所有数据。后续备份则为增量备份，只备份上次备份后发生变化的数据，以节约备份空间和时间。 无论是全量备份还是增量备份，云主机备份都能够快速、方便地将数据恢复到备份所在时刻的状态。您可以根据需要选择特定的备份进行恢复，备份之间相互独立，删除一份备份不会影响其他备份的使用。 云主机备份副本创建完成后，将默认存储在对象存储（单AZ）中，以实现数据的长期安全保存和灵活恢复。对象存储单AZ和多AZ的区别如下：单AZ数据会存储在一个可用区；多AZ数据会存储在同一地域的多个可用区中，可用性更高。 与云硬盘备份的差异 产品名称 备份/恢复对象 优势 产品要点说明 场景说明 云主机备份 以云主机为单位进行备份，云主机中的所有云硬盘（系统盘和数据盘）。 对云主机进行备份指的是同时对其上的所有云硬盘同时进行备份。 备份具有一致性，不存在因备份创建时间差带来的数据不一致问题。 整机备份，通过存储快照技术，将云主机包含的多个云硬盘的数据备份到对象存储。 周期备份、手动备份。支持恢复原云主机或创建新的云主机。 需要对整个云主机进行保护时，确保业务稳定性及数据安全。 云硬盘备份 以云硬盘为单位进行备份，指定的单个或多个云硬盘（系统盘或数据盘）。 能以更低的成本，更精细的粒度来确保数据安全。 通过存储快照技术，将云硬盘数据备份到对象存储。 周期备份、手动备份。支持恢复原云硬盘，使用备份数据创建新的云硬盘。 仅对数据盘或系统盘中的个人数据、隐私数据、重要数据进行备份时。

对象存储与函数计算集成后，对象存储事件能触发相关工作流执行，实现对对象存储中的数据的自定义处理。 背景信息 对象存储和工作流通过对象存储触发器实现无缝集成，可以编排工作流对对象存储事件进行自定义处理，当对象存储捕获到指定类型的事件后，对象存储事件触发相应的工作流执行。例如，可以设置工作流来处理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 对象解冻。

本文介绍事件总线EventBridge的产品优势。 可用性 支持高吞吐量的事件发布和消费。 支持服务Serverless化和自动弹性伸缩，轻松应对突发流量。 支持无状态实例，节点异常对服务无影响，服务可用性高。 易用性 支持无缝迁移上云，完全兼容CloudEvents 1.0。 支持多种访问方式，包括控制台与CloudEvents SDK。 支持接入多种应用程序，包括天翼云服务和自定义应用。 安全性 对接统一身份认证服务，支持通过天翼云账号向RAM用户授权。 支持HTTP/HTTPS协议。

事件目标是事件规则的一部分，负责消费经事件规则过滤与转换后的事件。 事件目标 事件总线EventBridge支持以下事件目标： 函数计算 分布式消息服务RocketMQ 分布式消息服务RabbitMQ 分布式消息服务Kafka HTTP、HTTPS地址

本文介绍如何在事件总线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

您可以通过事件规则过滤事件，将事件路由到函数计算。本文以自定义事件为例介绍将事件路由到函数计算的前提条件、操作步骤和结果验证。 前提条件 开通事件总线EventBridge并委托授权。 创建自定义总线。 开通函数计算、创建函数。 操作步骤 1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件总线。 2. 选择目标总线，点击事件源 按钮，点击添加事件源按钮，创建一个自定义事件源；填写事件源名，事件提供方可选择自定义应用。 3. 在左侧导航栏，单击事件规则 ，然后单击添加事件规则。 4. 在创建规则页面，完成以下操作。 1. 在配置基本信息 配置向导页面中，在名称 文本框输入规则名称，在描述文本框输入规则的描述，然后单击下一步。 2. 在配置事件模式配置向导页面中，在事件模式内容代码框输入事件模式，此处可选择匹配全部事件，然后单击下一步。如需了解更多信息，请参见事件模式。 3. 配置事件目标，函数计算目标参数描述如参数说明所示，然后单击创建，如图1所示。 图1 创建事件规则时选择服务类型为函数计算 参数说明 参数 说明 示例 函数 选择函数。 funxxx 函数版本与别名 支持指定函数版本或指定函数别名： 如果您选择指定版本，需要选择函数的具体版本。 如果您选择指定别名，需要选择函数的具体别名。 LATEST 执行方式 选择执行函数的方式：同步或异步。 同步 事件 选择调用到函数的事件内容，更多请参考事件内容转换。 完整事件

事件规则用于监控特定类型的事件。当发生与事件规则相匹配的事件时，事件会被路由到与事件规则关联的目标。事件规则可以与一个或多个目标关联。本文介绍如何在事件总线EventBridge管理控制台管理事件规则，包括创建、查看和删除事件规则等操作。 前提条件 开通事件总线EventBridge并委托授权。 创建规则 1. 登录事件总线管理控制台。 2. 在左侧导航栏，单击事件总线。 3. 在事件总线页面，单击目标总线名称。 4. 在左侧导航栏，单击事件规则。 5. 在事件规则 页面，单击创建规则。 6. 在创建规则页面，完成以下操作。 1. 在配置基本信息 配置向导，在名称 文本框输入规则名称，在描述 文本框输入规则的描述，然后单击下一步。 2. 在配置事件模式 配置向导，完成对应配置，然后单击下一步。 3. 在配置事件目标 配置向导，配置事件目标，然后单击创建。 注意 1个事件规则最多可以添加5个事件目标。 查看规则 在事件规则 页面，找到目标事件规则，在其右侧操作 列单击详情。 在规则详情页面查看规则的基础信息、事件模式和事件目标。 禁用规则 在事件规则 页面，找到目标事件规则，在其右侧操作 列选择更多 > 禁用。 启用规则 在事件规则 页面，找到目标事件规则，在其右侧操作 列选择更多 > 启用。 编辑事件目标 1. 在事件规则 页面，找到目标事件规则，在其右侧操作 列单击编辑事件目标。 2. 在编辑规则 页面，修改事件目标配置，然后单击确认。

事件总线类触发器 (尚未开放) 触发器名称 调用方式 详细介绍 日志触发器 同步/异步调用 根据云日志的事件类型触发工作流执行 对象存储触发器 同步/异步调用 根据对象存储的事件类型触发工作流执行

本章介绍如何对已经创建完成的备份策略进行修改。 如果原策略备份周期为按天备份，修改备份周期后，仍会按照创建策略的时间进行计算。例如：创建备份策略时设置每7天备份一次，按照创建策略时间开始计算，7天备份一次。如果3天后，将备份策略修改为5天备份一次，通常是希望修改当天之后5天开始备份，但实际上CSBS是在备份策略修改后2天开始备份，这个时间仍然是按照创建策略时间计算的，没有按照修改时间重新计算。 可以将原策略解绑后，再新建策略再重新绑定。 前提条件 已创建至少1个备份策略。 操作步骤 1. 登录云主机备份管理控制台。 登录管理控制台。 选择“存储 > 云主机备份”。 2. 选择“策略”页签。 3. 在需要修改的备份策略所在行单击“编辑”。 4. 在“编辑备份策略”页面进行修改，策略参数说明参考创建备份策略章节。 5. 单击“确定”。

您可使用开源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); } }

本文介绍如何应用事件总线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秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

事件总线EventBridge支持事件内容转换，即将事件源发出的符合CloudEvents 1.0协议的事件转换为事件目标可以接收的格式。本文介绍事件总线EventBridge提供的事件转换类型。 事件总线EventBridge支持的事件内容转换类型如下： 完整事件 当转化类型为完整事件时，事件总线EventBridge不对事件进行转换，将事件的完整结构路由到事件目标。 下表介绍经过完整事件转换前后的事件示例。 转换前的事件 转换类型 转换后的事件 plaintext { "id": "f36b49b668914b59b11cbf689xxxx712", "source": "ctyun:kafka", "type": "ctyun:kafka:Topic:Message", "specversion": "1.0", "datacontentype": "application/json;charsetutf8", "subject": "ctyun:kafka:75dcxx1eb5:topic:source1", "time": "20241203T09:48:00.696Z", "data": { "key": "test2", "value": "test1" } } 完整事件 plaintext { "id": "f36b49b668914b59b11cbf689xxxx712", "source": "ctyun:kafka", "type": "ctyun:kafka:Topic:Message", "specversion": "1.0", "datacontentype": "application/json;charsetutf8", "subject": "ctyun:kafka:75dcxx1eb5:topic:source1", "time": "20241203T09:48:00.696Z", "data": { "key": "test2", "value": "test1" } } 部分事件 当转换类型为部分事件时，事件总线EventBridge通过JSONPath从符合CloudEvents格式的事件中提取事件中的参数，将指定的事件内容路由到事件目标。 下表介绍经过部分事件转换前后的事件示例。