使用 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)