1

spring-xd-1.0.0.M6 を使用しています。

Spring-xd のシンクとして mysql DB を構成しようとしています

私は従う - http://theblasfrompas.blogspot.in/2014/01/springxd-filetail-input-ingestion-jdbc.html

jdbc.properties ファイルを入れました -

1)spring-xd-1.0.0.M6/xd/modules/sink/jdbc/config 場所

2) mysql コネクタ jar を

spring-xd-1.0.0.M6/xd/lib

ファイル-input.txtを作成し、フォルダーに入れます-/<some path>/temp/input.txt

ファイルには

{"id":"1","name":"pas"}
{"id":"2","name":"lucia"}
{"id":"3","name":"lucas"}
{"id":"4","name":"siena"}

jdbc ファイルには、次の情報が含まれています。

driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/spring_xd
username=root
password=root

XDシェルで次のように実行します

stream create --name filetest --definition "tail --name='/<some path>/temp/input.txt' |  jdbc --columns='id,name'" --deploy

私のmysql DBテーブル名は-file_testで、idとnameの2つの列があります-で述べたのと同じですExample Link

しかし、私は得る

Command failed org.springframework.xd.rest.client.impl.SpringXDException: Error with option(s) for module jdbc of type sink:
    columns: option named 'columns' is not supported

tableName パラメータを指定すると、..

tableName: option named 'tableName' is not supported

私も参照しています - https://github.com/spring-projects/spring-xd/pull/621

しかし、手がかりは少ない....最新のSpring-xdビルド

4

1 に答える 1

0

.properties ファイルを置くディレクトリは、モジュールを構成するためのものではなく、使用可能なオプションを宣言するためのものです。そこに置くことで、基本的にjdbcモジュールにオプションがないことを宣言したことになります (実際には正しい構文を使用していないため)。

代わりに、他の場所で言及した .properties ファイルを配置する必要があります。ピックアップされる正確な場所は、リリース間で変更されていることに注意してください。最新リリース (執筆時点では M7) を使用することをお勧めします。すると、正しい位置は

${xd.home}/config/modules/sink/jdbc/jdbc.properties

そしてそうではない

${xd.home}/modules/sink/jdbc/config/jdbc.properties

現在、XD リリースでは、すぐに使用できるこのようなファイルが提供されていることに注意してください。その内容は次のようになります。

url = ${spring.datasource.url}
driverClassName = ${spring.datasource.driverClassName}
username = ${spring.datasource.username}
password = ${spring.datasource.password}

これは、jdbc モジュールがserver.ymlデフォルトで定義された値を使用するようにするためです。

于 2014-06-16T13:46:07.780 に答える