代码拉取完成,页面将自动刷新
名称:pgwalreader
PostgreSQL数据库版本至少为10.0及以上
1、预写日志级别(wal_level)必须为logical
2、该插件基于PostgreSQL逻辑复制及逻辑解码功能实现的,因此PostgreSQL账户至少拥有replication权限,若允许创建slot,则至少拥有超级管理员权限
3、详细原理请参见PostgreSQL官方文档
jdbcUrl
username
password
tableList
cat
statusInterval
lsn
slotName
allowCreateSlot
temporary
pavingData
{
"type":"update",
"schema":"dbo",
"table":"customers",
"lsn":207967352,
"ts": 1576487525488,
"ingestion":1475129582923642,
"before_id":1,
"after_id":2
}
pavingData为false时:
{
"type":"update",
"schema":"dbo",
"table":"customers",
"lsn":207967352,
"ts": 1576487525488,
"ingestion":1481628798880038,
"before":{
"id":1
},
"after":{
"id":2
}
}
其中:ts是数据库中数据的变更时间,ingestion是插件解析这条数据的纳秒时间,lsn是该数据变更的日志序列号
{
"job": {
"content": [{
"reader" : {
"parameter" : {
"username" : "username",
"password" : "password",
"url" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"databaseName" : "postgres",
"cat" : "update,insert,delete",
"tableList" : [
"changepk.test_table"
],
"statusInterval" : 10000,
"lsn" : 0,
"slotName" : "",
"allowCreateSlot" : true,
"temporary" : true,
"pavingData" : true
},
"name" : "pgwalreader"
},
"writer" : {
"parameter" : {
"print" : true
},
"name" : "streamwriter"
}
} ],
"setting": {
"speed": {
"channel": 1,
"bytes": 0
},
"errorLimit": {
"record": 100
},
"restore": {
"maxRowNumForCheckpoint": 0,
"isRestore": false,
"isStream" : true,
"restoreColumnName": "",
"restoreColumnIndex": 0
},
"log" : {
"isLogger": false,
"level" : "debug",
"path" : "",
"pattern":""
}
}
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。