使用Apache-flink将处理过的流数据存入数据库

Question

是否可以使用pyflink将处理过的流数据存入数据库？所有写入已处理数据的方法都被限制为以txt、csv或Json格式保存它们，并且没有办法将数据与数据库一起接收。

Answer 1

您可以在pyflink中使用SQL来定义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)