MySQL连接类型,创建MySQL连接,连接测试,Catalog挂载-事件总线(EventBridge)-阿里云帮助中心

本文介绍 EventBridge 中 MySQL 连接类型的参数定义、创建方式和注意事项。

概述

MySQL 连接类型用于建立 EventBridge 与 MySQL 数据库之间的连通性。创建 MySQL 连接后，可在 EventHouse 数据目录（Catalog）中挂载该连接，将 MySQL 表映射为可查询的事件表。

支持的 MySQL 实例：

阿里云 RDS MySQL（5.7 及以上版本，推荐 8.0）
阿里云 PolarDB MySQL
自建 MySQL 实例

连接参数

参数	字段名	类型	是否必填	说明
主机地址	HostName	string	是	MySQL 主机地址。RDS 实例填写实例域名（如 `rm-xxx.mysql.rds.aliyuncs.com`），自建实例填写 IP 地址。
端口号	Port	string	是	MySQL 端口号，通常是 `3306`。
用户名	User	string	是	数据库连接用户名。建议使用只读账号。
密码	Password	string	是	数据库连接密码。
数据库名称	DatabaseName	string	是	要连接的数据库名称。

参数示例

{
  "HostName": "rm-bp1xxxxx.mysql.rds.aliyuncs.com",
  "Port": "3306",
  "User": "readonly_user",
  "Password": "your_password",
  "DatabaseName": "order_db"
}

创建 MySQL 连接

通过控制台创建

登录事件总线EventBridge控制台。
在左侧导航栏，选择集成中心 > 连接管理。
在顶部菜单栏，选择地域，然后单击创建连接。
连接类型选择 MySQL，填写连接参数。
单击测试连接验证连通性。
测试通过后，单击确定。

通过 API 创建

使用 CreateConnection API 创建 MySQL 连接：

{
  "ConnectionName": "my-mysql-conn",
  "Type": "MySQL",
  "Parameters": {
    "HostName": "rm-bp1xxxxx.mysql.rds.aliyuncs.com",
    "Port": "3306",
    "User": "readonly_user",
    "Password": "your_password",
    "DatabaseName": "order_db"
  }
}

网络配置

网络类型	说明	适用场景
公网	通过公网连接，无需额外配置	MySQL 实例已开放公网访问（RDS 需开启外网地址）
VPC 私网	通过 VPC 内网连接	MySQL 实例部署在 VPC 内

使用 VPC 私网时，需额外配置：

VPC ID：MySQL 实例所在 VPC。
交换机 ID（VSwitch ID）：VPC 内的交换机。
安全组 ID：安全组入方向规则需放行 MySQL 端口（3306）。

EventBridge 会自动打通与客户 VPC 的网络连通，无需客户侧做额外网络对接。

使用场景

Catalog 挂载（已支持）

将 MySQL 连接挂载到 EventHouse Catalog，即可通过 SQL 直接查询 MySQL 表：

-- 查询 MySQL 中的订单表
SELECT * FROM my_catalog.order_namespace.orders LIMIT 10;

-- 跨源 JOIN：MySQL 订单表与 EventHouse 事件表
SELECT o.order_id, o.amount, e.event_type
FROM my_catalog.order_namespace.orders o
JOIN my_catalog.event_namespace.payment_events e
  ON o.order_id = e.order_id;

详细操作请参见数据目录 Catalog。

权限要求

建议为 EventBridge 创建专用的只读账号：

-- 创建只读用户
CREATE USER 'eb_readonly'@'%' IDENTIFIED BY 'your_password';
-- 授予只读权限
GRANT SELECT ON order_db.* TO 'eb_readonly'@'%';
FLUSH PRIVILEGES;

EventBridge 仅需 SELECT 权限，不会修改 MySQL 中的数据。

常见问题

Q：测试连接失败，提示 "Connection refused"？

A：请检查：

MySQL 实例是否正常运行。
主机地址和端口是否正确。RDS 实例使用内网地址还是外网地址。
白名单或安全组是否放行了 3306 端口。
如果使用 VPC 私网，确认 VPC 和交换机配置正确。

Q：测试连接成功但挂载后查询报 "Access denied"？

A：测试连接仅验证网络连通性和基本认证。挂载后查询需要用户对目标表具有 SELECT 权限。请确认授权范围覆盖了要查询的表。

Q：连接创建后能否修改参数？

A：可以修改主机地址、端口、用户名、密码和数据库名称。连接名称和连接类型创建后不可修改。