做设计找素材那个网站最好用,手机软件app,app网站模板下载,番禺建网站价格MysqlCdc组件
组件说明
MySQL CDC连接器允许从MySQL数据库读取快照数据和增量数据。
计算引擎
flink
组件分组
cdc
端口
Inport#xff1a;默认端口
outport#xff1a;默认端口
组件属性
名称展示名称默认值允许值是否必填描述例子hostnameHostname“”无是MySQL…MysqlCdc组件
组件说明
MySQL CDC连接器允许从MySQL数据库读取快照数据和增量数据。
计算引擎
flink
组件分组
cdc
端口
Inport默认端口
outport默认端口
组件属性
名称展示名称默认值允许值是否必填描述例子hostnameHostname“”无是MySQL 数据库服务器的IP地址或主机名。127.0.0.1usernameUsername“”无是连接到MySQL数据库服务器时要使用的MySQL用户的名称。rootpasswordPassword“”无连接MySQL数据库服务器时使用的密码。JDBC用户名。如果指定了username和password中的任一参数则两者必须都被指定。123456databaseNameDatabaseName“”无是要监视的MySQL服务器的数据库名称。数据库名称还支持正则表达式以监视多个与正则表达式匹配的表。testtableNameSCHEMA“”无是连接到JDBC表的名称。testtableNameTableName“”无否需要监视的 MySQL 数据库的表名。表名支持正则表达式以监视满足正则表达式的多个表。注意MySQL CDC 连接器在正则匹配表名时会把用户填写的 database-name table-name 通过字符串 \\. 连接成一个全路径的正则表达式然后使用该正则表达式和 MySQL 数据库中表的全限定名进行正则匹配。testportPort3306无否MySQL数据库服务器的整数端口号。。3306serverIdServerId“”无否读取数据使用的 server idserver id 可以是个整数或者一个整数范围比如 ‘5400’ 或 ‘5400-5408’, 建议在 ‘scan.incremental.snapshot.enabled’ 参数为启用时配置成整数范围。因为在当前 MySQL 集群中运行的所有 slave 节点标记每个 salve 节点的 id 都必须是唯一的。 所以当连接器加入 MySQL 集群作为另一个 slave 节点并且具有唯一 id 的情况下它就可以读取 binlog。 默认情况下连接器会在 5400 和 6400 之间生成一个随机数但是我们建议用户明确指定 Server id。tableDefinitionTableDefinition“”无是Flink table定义。propertiesPROPERTIES“”无否连接器其他配置。
MysqlCdc示例配置
{flow: {name: MysqlCdcTest,uuid: 1234,stops: [{uuid: 0000,name: MysqlCdc1,bundle: cn.piflow.bundle.flink.cdc.mysql.MysqlCdc,properties: {hostname: 127.0.0.1,port: 3306,username: root,password: 123456,databaseName: test,tableName: test,tableDefinition: {\catalogName\:null,\dbname\:null,\tableName\:\\,\ifNotExists\:true,\physicalColumnDefinition\:[{\columnName\:\id\,\columnType\:\INT\,\comment\:\id\,\primaryKey\:true},{\columnName\:\name\,\columnType\:\STRING\,\comment\:\name\},{\columnName\:\age\,\columnType\:\INT\}],\metadataColumnDefinition\:null,\computedColumnDefinition\:null,\watermarkDefinition\:null},properties: {\server-time-zone\:\Asia/Shanghai\}}},{uuid: 2222,name: ShowData1,bundle: cn.piflow.bundle.flink.common.ShowChangeLogData,properties: {showNumber: 100}}],paths: [{from: MysqlCdc1,outport: ,inport: ,to: ShowData1}]}
}示例说明
本示例演示了通过MysqlCdc从数据库test中读取test表数据并使用ShowChangeLogData组件将数据打印在控制台。
演示DEMO PiflowX-MysqlCdc组件
