Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feature][Sort] Add audit for PostgreSQL extract node #5460

Closed
2 tasks done
gong opened this issue Aug 10, 2022 · 0 comments · Fixed by #5546
Closed
2 tasks done

[Feature][Sort] Add audit for PostgreSQL extract node #5460

gong opened this issue Aug 10, 2022 · 0 comments · Fixed by #5546

Comments

@gong
Copy link
Contributor

gong commented Aug 10, 2022

Description

Add Audit for postgreSQL extract node

Use case

User only need add with param "inlong.audit":"<host>&<port>" when using flink sql.
But user must set inlong.metric when set inlong.audit.
for example:
with param "inlong.metric":"<groupId>&<streamId>&<nodeId>"

example:

  create table `table_groupId_streamId_nodeId1`(
    `age` INT,
    `name` STRING,
    PRIMARY KEY(`age`) NOT ENFORCED)
    WITH (
    'connector' = 'postgres-cdc-inlong',
    'hostname' = 'xxxx',
    'port' = '5432',
    'username' = 'postgres',
    'password' = 'xxx',
    'database-name' = 'postgres',
    'schema-name' = 'public',
    'table-name' = 'user',
     'decoding.plugin.name' = 'pgoutput',
  'slot.name' = 'feaafacbaddadc',
   'inlong.audit' = 'host&port',
   'inlong.metric' = 'pgGroup&pgStream&pgNode1'
);

CREATE TABLE `table_groupId_streamId_nodeId2`(
    PRIMARY KEY (`name`,`age`) NOT ENFORCED,
    `name` STRING,
    `age` INT)
    WITH (
    'connector' = 'print'
);

   INSERT INTO `table_groupId_streamId_nodeId2`
    SELECT
    `name` AS `name`,
    `age` AS `age`
    FROM `table_groupId_streamId_nodeId1`;

It will send audit data to audit service

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

@healchow healchow changed the title [Feature][Sort] Add Audit for postgreSQL extract node [Feature][Sort] Add audit for PostgreSQL extract node Aug 16, 2022
@healchow healchow added this to the 1.3.0 milestone Aug 16, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants