在 WSO2 ESB 外序列代理服务中配置 Hadoop 端点答案

【问题标题】：Configuring Hadoop endpoint in a WSO2 ESB outsequence proxy service在 WSO2 ESB 外序列代理服务中配置 Hadoop 端点
【发布时间】：2015-10-22 13:42:03
【问题描述】：

我必须为 WSO2 ESB 中代理服务的外序列设置一个 Hadoop 端点。我应该将 WS 响应护送到 Hadoop 文件存储库中。以下是在 Hadoop 上写入文件的 PUT 命令的语法： 2-step commands for file-writing

如何实现一个工作代理，以在 Hadoop 上保存 WS 响应的顺序执行这 2 个步骤？

【问题讨论】：

标签： web-services hadoop proxy wso2 wso2esb

【解决方案1】：

首先，在 inSequence 中，您可以使用 call mediator 进行调用以请求 url。

     <call>
        <endpoint>
           <address uri="http://localhost:9000/services/YourService"/>
        </endpoint>
     </call>

接下来，您可以从上述响应中提取标头并将其设置为下一个请求的“To”标头。然后使用 send 或 call mediator 使用“默认”端点发送内容（默认端点通过查看“To”标头将消息发送到正确的地址）。

<header name="To"
             scope="transport"
             expression="get-property('redirectUri')"/>

this page describes 中的示例 5 如何使用默认（动态）端点。

更新：

由于您需要调用外部 REST 服务并将其保存到 hadoop，因此基本流程如下所示：

首先你向 hadoop 端点创建一个<call> 并获取用于保存数据的 url。
从上述响应中，提取标头并将其保存到属性中。
<property name"redirectUri" expression="get-property('hadoop_response_header_name')" scope="transport"/>
接下来，您可以再次使用调用中介调用其余服务。在调用它之前，您可能必须使用 Payload Factory 中介构建一个 json 有效负载。还要确保在此处声明端点时，将正确的格式添加为“rest”（请阅读此处的地址端点）。
当您收到来自 REST 服务的响应时，您可以再次使用有效负载工厂对收到的响应进行任何必要的修改，以构建格式正确的请求来调用 hadoop 端点。
最后，您可以将请求发送到 hadoop 端点。在此处调用发送中介之前，您需要设置上面给出的“To”标头（使用之前提取的属性“redirectUri”）并使用默认端点。

您需要阅读一些关于端点、有效负载工厂中介、调用中介、属性中介和标头中介的信息才能使其正常工作。

【讨论】：

那么，当我创建代理服务时，我必须同时放置一个 inSequence 和一个端点吗？如何提取答案的标题？
一切都可以进入inSequence。在我上面提供的第二个代码段中，您可以看到如何获取/设置标头（将“redirectUri”替换为实际标头名称）
问题是我必须创建一个代理来向 REST 服务（如api.openweathermap.org）请求数据集，然后必须将结果存储在 Hadoop 系统中，根据hadoop.apache.org/docs/r2.4.1/hadoop-project-dist/hadoop-hdfs/….
我无法获得 hadoop 响应，如何插入我在语法中找到的 che curl 参数以获得重定向？然后，我认为我应该在第一步和第二步之间插入一个标头调解器，不是吗？感谢您的耐心等待。