我如何处理一些数据并通过 Spring 将其存储到多个表 XD Sink

Question

我正在使用 spring xd 从原始 table 获取数据并对其进行处理，然后将其存储到多个 tables。

我成功存储到一个 table 中。

我面临的问题是如何使用 Spring XD sink jdbc.

将数据存储到多个 tables

目前我正在通过以下代码创建流。它将从原始 table(raw_device_data) 获取数据并在处理后将其存储到 sleep_analysis table.

stream create db --definition "source:jdbc --query='select data from raw_device_data where id=330' --url=jdbc:postgresql://localhost:5432/rahar --driverClassName=org.postgresql.Driver --username=postgres --password=root --outputType=application/json | customProcessor15 | sink:jdbc --tableName=sleep_analysis --initializeDatabase=true --columns=latency,sleep_duration,sleep_efficiency,total_minutes_in_bed,total_sleep_time,wakefulness --url=jdbc:postgresql://localhost:5432/rahar --driverClassName=org.postgresql.Driver --username=postgres --password=root"  --deploy

我想将处理后的数据存储到多个table中。

谢谢。

Answer 1

将结果发送到 topic 命名频道。创建两个（或更多）流以从该主题中使用 - 请参阅 the documentation.

foo | bar > topic:result

topic:result > jdbc1

topic:result > jdbc2

我如何处理一些数据并通过 Spring 将其存储到多个表 XD Sink

How Can I prcoess some data and store it to multiple tables through Spring XD Sink

java

spring

spring-xd