使用 SpringXD 的通配符 SQL 查询答案

【问题标题】：Wildcarding SQL query using SpringXD使用 SpringXD 的通配符 SQL 查询
【发布时间】：2016-05-15 17:13:55
【问题描述】：

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

【问题讨论】：

标签： sql wildcard spring-xd spring-cloud-dataflow

【解决方案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()

【讨论】：