Changefeed
平凯数据库云服务 changefeed 帮助你将数据从平凯数据库云服务流式传输到其他下游系统。目前,平凯数据库云服务支持将数据流式传输到 Apache Kafka 和 MySQL。
注意
- 目前,平凯数据库云服务每个 平凯云 Essential 实例最多只允许创建 10 个 changefeed。
- 对于 平凯云 Starter 实例,changefeed 功能不可用。
限制
- changefeed 不支持在单个
RENAME TABLE语句中重命名多个表的 DDL 语句,例如RENAME TABLE t1 TO t3, t2 TO t4。执行该语句会永久中断 changefeed 的数据同步。 - changefeed 的吞吐约为 20 MiB/s。如果你的增量数据量超过此限制,请联系平凯云技术支持获取帮助。
支持的区域
changefeed 功能目前在以下区域可用:
| 云服务商 | 支持的区域 |
|---|---|
| 阿里云 | 支持情况请以平凯数据库云服务控制台为准 |
| 腾讯云 | 支持情况请以平凯数据库云服务控制台为准 |
未来将支持更多区域。如果你需要在特定区域立即支持,请联系凯云技术支持。
查看 Changefeed 页面
要访问 changefeed 功能,请按照以下步骤操作:
-
登录 平凯数据库云服务控制台,并进入集群列表页面。
提示:
如果你属于多个组织,请先使用左上角的下拉框切换到目标组织。
-
点击目标 平凯云 Essential 实例名称进入其概览页面,然后在左侧导航栏点击 Data > Changefeed。此时会显示 changefeed 页面。
在 Changefeed 页面,你可以创建 changefeed,查看已有 changefeed 列表,并对已有 changefeed 进行操作(如暂停、恢复、修改/编辑和删除 changefeed)。
创建 changefeed
要创建 changefeed,请参考以下教程:
查看 changefeed
你可以通过平凯数据库云服务控制台或平凯数据库云服务 CLI 查看 changefeed。
- 进入目标 平凯云 Essential 实例的 Changefeed 页面。
- 找到你想要查看的 changefeed,在 Action 列点击 ... > View。
- 你可以查看 changefeed 的详细信息,包括其配置、状态和统计/指标(信息)。
运行以下命令:
ticloud serverless changefeed get --cluster-id <cluster-id> --changefeed-id <changefeed-id>暂停或恢复 changefeed
你可以通过平凯数据库云服务控制台或平凯数据库云服务 CLI 暂停或恢复 changefeed。
- 进入目标 平凯云 Essential 实例的 Changefeed 页面。
- 找到你想要暂停或恢复的 changefeed,在 Action 列点击 ... > Pause/Resume。
要暂停 changefeed,运行以下命令:
ticloud serverless changefeed pause --cluster-id <cluster-id> --changefeed-id <changefeed-id>要恢复 changefeed:
ticloud serverless changefeed resume -c <cluster-id> --changefeed-id <changefeed-id>修改/编辑 changefeed
注意
平凯数据库云服务目前仅允许在 changefeed 处于暂停状态时进行修改/编辑。
你可以通过平凯数据库云服务控制台或平凯数据库云服务 CLI 修改/编辑 changefeed。
-
进入目标 平凯云 Essential 实例的 Changefeed 页面。
-
找到你想要暂停的 changefeed,在 Action 列点击 ... > Pause。
-
当 changefeed 状态变为
Paused后,点击 ... > Edit 以修改/编辑对应的 changefeed。平凯数据库云服务默认填充 changefeed 配置。你可以修改以下配置:
- Apache Kafka sink:除 Destination、Connection 和 Start Position 外的所有配置
- MySQL sink:除 Destination、Connection 和 Start Position 外的所有配置
-
修改配置后,点击 ... > Resume 以恢复对应的 changefeed。
编辑 Apache Kafka sink 的 changefeed:
ticloud serverless changefeed edit --cluster-id <cluster-id> --changefeed-id <changefeed-id> --name <new-displayName> --kafka <full-specified-kafka> --filter <full-specified-filter>编辑 MySQL sink 的 changefeed:
ticloud serverless changefeed edit --cluster-id <cluster-id> --changefeed-id <changefeed-id> --name <new-displayName> --mysql <full-specified-mysql> --filter <full-specified-filter>复制 changefeed
- 进入目标 平凯云 Essential 实例的 Changefeed 页面。
- 找到你想要复制的 changefeed,在 Action 列点击 ... > Duplicate。
- 平凯数据库云服务会自动用原有设置填充新 changefeed 的配置。你可以根据需要检查并修改配置。
- 确认配置后,点击 Submit 创建并启动新的 changefeed。
删除 changefeed
你可以通过平凯数据库云服务控制台或平凯数据库云服务 CLI 删除 changefeed。
- 进入目标 平凯云 Essential 实例的 Changefeed 页面。
- 找到你想要删除的 changefeed,在 Action 列点击 ... > Delete。
运行以下命令:
ticloud serverless changefeed delete --cluster-id <cluster-id> --changefeed-id <changefeed-id>changefeed 计费
对于 2026 年 7 月 1 日之前创建的现有 平凯云 Essential 实例,changefeed 免费。
从 2026 年 7 月 1 日起,changefeed 对新创建的 平凯云 Essential 实例按功能收费。有关计费详情,请参见 平凯数据库云服务 Essential Pricing Details。
changefeed 状态
在运行过程中,changefeed 可能因错误而失败,或被手动暂停或恢复。这些操作会导致 changefeed 状态发生变化。
各状态说明如下:
CREATING:changefeed 正在创建中。CREATE_FAILED:changefeed 创建失败。你需要删除该 changefeed 并重新创建。RUNNING:changefeed 正常运行,checkpoint-ts 正常推进。PAUSED:changefeed 已暂停。WARNING:changefeed 返回警告。由于某些可恢复错误,changefeed 无法继续。处于该状态的 changefeed 会持续尝试恢复,直到状态变为RUNNING。该状态下的 changefeed 会阻塞 GC 操作。RUNNING_FAILED:changefeed 运行失败。由于某些错误,changefeed 无法恢复且无法自动修复。如果在增量数据的垃圾回收(GC)之前解决了问题,你可以手动恢复失败的 changefeed。增量数据的默认生存时间(TTL)为 24 小时,即 changefeed 中断后 24 小时内 GC 机制不会删除任何数据。