通过这种方式也能吧数据写入pg里面嘛？

是的，您可以使用阿里云实时计算Flink版将数据写入云原生数据仓库AnalyticDB PostgreSQL版（ADB PG）中。具体操作步骤如下：

1. 配置sink表：在Flink作业中定义一个临时表（sink表），指定与ADB PG相关的连接参数，包括url、tablename、username和password等。例如：

   CREATE TEMPORARY TABLE sink_adbpg (
    id int,
    username varchar,
    score int
   ) WITH (
    'connector' = 'adbpg', 
    'url' = 'jdbc:postgresql://yourADBPGInstanceURL:5432/yourDatabase',
    'tablename' = 'adbpg_sink_table',  
    'username' = 'yourUsername',
    'password' = 'yourPassword',
    'maxRetryTimes' = '2',
    'conflictMode' = 'ignore',
    'retryWaitTime' = '200'
   );
   

2. 编写插入语句：在Flink SQL中编写INSERT INTO语句，从数据源（如datagen_source表）选择数据并插入到刚创建的sink表中：

   INSERT INTO sink_adbpg
   SELECT ts.id,ts.username,ds.score
   FROM datagen_source AS ds
   JOIN dim_adbpg FOR SYSTEM_TIME AS OF PROCTIME() AS ts
   on ds.id = ts.id;
   

3. 部署并启动作业：在Flink作业开发页面完成语法检查后，部署该作业，并在运维中心启动它。

4. 查看结果：登录ADB PG控制台，通过执行SQL查询语句来验证数据是否成功写入：

   SELECT * FROM adbpg_sink_table ORDER BY id;
   

确保在操作前已正确设置ADB PG的访问权限和网络配置，且Flink作业中的数据库连接信息与ADB PG实例的实际信息相匹配。这样，您就可以实现将数据通过Flink实时写入到PostgreSQL数据库中了。