0

我有一个用例，我需要每天将数据从基于 SQL 的仓库移动到 mongo。我们选择 SpringXD 作为这个 ETL 工作的工具。但是，我需要将一些通配符参数传递给我的查询，这些参数每天都在变化。我想知道是否有人知道或可以为我提供一个示例 DSL，用于在使用 Spring XD 时将通配符参数传递给 SQL 选择查询。

4

1 回答 1

1

嘿，所以这将是 SpringXD Rest API 的一个很好的用途。 http://docs.spring.io/spring-xd/docs/1.3.1.RELEASE/reference/html/#REST-API

您可以做的是有一个小脚本或应用程序，以编程方式使用您想要的作业参数部署您的流。假设您有一个工作“myBatchJob”和两个会改变的参数。您所要做的就是将字符串参数编码到响应中，然后您可以根据需要随时更改参数！这是一个 Python 示例，将作业部署发布到 XD Rest API。获得正确的编码参数可能有点棘手，但值得努力以获得您正在寻找的灵活性

       import urllib2
       req = urllib2.Request('http://localhost:9393/jobs/executions?jobParameters=%7B%22-myParameter1(string)%22:%22foo%22,%22-myParameter2(string)%22:%22bar%22%7D&jobname=myBatchJob')
       response = urllib2.urlopen(req)
       print response.read()
于 2016-06-21T15:14:16.800 回答