Skip to content

Commit ab70a29

Browse files
[minor][hotfix][docs] Fix some error in postgres yaml document. (#4140)
1 parent 83ef3de commit ab70a29

File tree

2 files changed

+31
-21
lines changed
  • docs
    • content.zh/docs/connectors/pipeline-connectors
    • content/docs/connectors/pipeline-connectors

2 files changed

+31
-21
lines changed

docs/content.zh/docs/connectors/pipeline-connectors/postgres.md

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ Postgres CDC Pipeline 连接器允许从 Postgres 数据库读取快照数据和
3131

3232
## 示例
3333

34-
从 Postgres 读取数据同步到 Doris 的 Pipeline 可以定义如下:
34+
从 Postgres 读取数据同步到 Fluss 的 Pipeline 可以定义如下:
3535

3636
```yaml
3737
source:
@@ -41,19 +41,23 @@ source:
4141
port: 5432
4242
username: admin
4343
password: pass
44-
tables: adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+, [app|web].schema_\.*.order_\.*
44+
# 需要确保所有的表来自同一个database
45+
tables: adb.\.*.\.*
4546
decoding.plugin.name: pgoutput
4647
slot.name: pgtest
4748

4849
sink:
49-
type: doris
50-
name: Doris Sink
51-
fenodes: 127.0.0.1:8030
52-
username: root
53-
password: pass
50+
type: fluss
51+
name: Fluss Sink
52+
bootstrap.servers: localhost:9123
53+
# Security-related properties for the Fluss client
54+
properties.client.security.protocol: sasl
55+
properties.client.security.sasl.mechanism: PLAIN
56+
properties.client.security.sasl.username: developer
57+
properties.client.security.sasl.password: developer-pass
5458

5559
pipeline:
56-
name: Postgres to Doris Pipeline
60+
name: Postgres to Fluss Pipeline
5761
parallelism: 4
5862
```
5963
@@ -105,8 +109,9 @@ pipeline:
105109
<td style="word-wrap: break-word;">(none)</td>
106110
<td>String</td>
107111
<td>需要监视的 Postgres 数据库的表名。表名支持正则表达式,以监视满足正则表达式的多个表。<br>
108-
需要注意的是,点号(.)被视为数据库和表名的分隔符。 如果需要在正则表达式中使用点(.)来匹配任何字符,必须使用反斜杠对点进行转义。<br>
109-
例如,adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+, [app|web].schema_\.*.order_\.*</td>
112+
需要确保所有的表来自同一个数据库。<br>
113+
需要注意的是,点号(.)被视为数据库、模式和表名的分隔符。 如果需要在正则表达式中使用点(.)来匹配任何字符,必须使用反斜杠对点进行转义。<br>
114+
例如,bdb.user_schema_[0-9].user_table_[0-9]+, bdb.schema_\.*.order_\.*</td>
110115
</tr>
111116
<tr>
112117
<td>slot.name</td>

docs/content/docs/connectors/pipeline-connectors/postgres.md

Lines changed: 16 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -32,29 +32,33 @@ Note: Since the Postgres WAL log cannot parse table structure change records, Po
3232

3333
## Example
3434

35-
An example of the pipeline for reading data from Postgres and sink to Doris can be defined as follows:
35+
An example of the pipeline for reading data from Postgres and sink to Fluss can be defined as follows:
3636

3737
```yaml
3838
source:
39-
type: posgtres
39+
type: postgres
4040
name: Postgres Source
4141
hostname: 127.0.0.1
4242
port: 5432
4343
username: admin
4444
password: pass
45-
tables: adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+, [app|web].schema_\.*.order_\.*
45+
# make sure all the tables share same database.
46+
tables: adb.\.*.\.*
4647
decoding.plugin.name: pgoutput
4748
slot.name: pgtest
4849

4950
sink:
50-
type: doris
51-
name: Doris Sink
52-
fenodes: 127.0.0.1:8030
53-
username: root
54-
password: pass
51+
type: fluss
52+
name: Fluss Sink
53+
bootstrap.servers: localhost:9123
54+
# Security-related properties for the Fluss client
55+
properties.client.security.protocol: sasl
56+
properties.client.security.sasl.mechanism: PLAIN
57+
properties.client.security.sasl.username: developer
58+
properties.client.security.sasl.password: developer-pass
5559

5660
pipeline:
57-
name: Postgres to Doris Pipeline
61+
name: Postgres to Fluss Pipeline
5862
parallelism: 4
5963
```
6064
@@ -106,9 +110,10 @@ pipeline:
106110
<td style="word-wrap: break-word;">(none)</td>
107111
<td>String</td>
108112
<td>Table name of the Postgres database to monitor. The table-name also supports regular expressions to monitor multiple tables that satisfy the regular expressions. <br>
109-
It is important to note that the dot (.) is treated as a delimiter for database and table names.
113+
All the tables are required to share same database. <br>
114+
It is important to note that the dot (.) is treated as a delimiter for database, schema and table names.
110115
If there is a need to use a dot (.) in a regular expression to match any character, it is necessary to escape the dot with a backslash.<br>
111-
例如,adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+, [app|web].schema_\.*.order_\.*</td>
116+
for example: bdb.user_schema_[0-9].user_table_[0-9]+, bdb.schema_\.*.order_\.*</td>
112117
</tr>
113118
<tr>
114119
<td>slot.name</td>

0 commit comments

Comments
 (0)