python - 使用 Apache-flink 将处理后的流数据汇入数据库

Question

是否可以使用 pyflink 将处理后的流数据沉入数据库？所有写入处理数据的方法都仅限于将它们保存为txt、csv或Json格式，并且无法将数据下沉到数据库中。

Answer 1

您可以在 pyflink 中使用 SQL DDL 来定义一个 JDBC 表接收器，然后您可以将其插入。看起来像这样

my_sink_ddl = """
CREATE TABLE MyUserTable (
  id BIGINT,
  name STRING,
  age INT,
  status BOOLEAN,
  PRIMARY KEY (id) NOT ENFORCED
) WITH (
   'connector' = 'jdbc',
   'url' = 'jdbc:mysql://localhost:3306/mydatabase',
   'table-name' = 'users'
);
"""

t_env.sql_update(my_sink_ddl)