使用SpringXD的SQL查询通配符

Question

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

Answer 1

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

您可以使用一个小脚本或应用程序，以编程方式使用所需的作业参数部署流。假设您有一个作业"myBatchJob"和两个将更改的参数。您所要做的就是将String参数编码到响应中，然后您可以随时更改参数！这是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()