WSO2 EI DATASERVICE用作序列调用的REST API

Question

我是WSO2的新手，目前我正在尝试将MongoDB数据服务作为REST API展示。我遵循本教程，并将数据服务揭露为这样的REST资源：

<data>
  <config>...</config>
   <query id="count" useConfig="MongoDB">
      <expression>myCollection.count()</expression>
      <result outputType="json">{&#xd;"Documents": {&#xd;"Document": [&#xd;{&#xd;"Data": "$document"&#xd;}&#xd;]&#xd;}&#xd;}</result>
   </query>
   
   <operation name="count_op">
      <call-query href="count"/>
   </operation>
   
   <resource method="GET" path="users/count">
      <call-query href="count"/>
   </resource>
</data>

工作正常，但是当我尝试从Angular2项目访问资源时，我偶然发现了CORS问题。我阅读了一些有关此的帖子，并认为我需要使用类似的内容来修改我的REST API：

<resource methods="OPTIONS" url-mapping="/*">
       <inSequence>
           <property action="set" name="HTTP_SC" scope="axis2"
               type="STRING" value="200"/>
           <property action="set" name="messageType" scope="axis2"
               type="STRING" value="application/json"/>
           <sequence key="rest_add_access_control_headers"/>
           <respond/>
       </inSequence>
       <outSequence/>
       <faultSequence>
           <sequence key="rest_add_access_control_headers"/>
           <respond/>
       </faultSequence>
   </resource>

我试图将此代码与我的数据服务定义(上面的一个(集成在一起，但是我无法正常工作，这让我想知道数据服务是否与REST资源相同，与REST API相同？看来我无法在数据服务定义中调用任何元素或其他调解人。我需要为此创建实际的REST API吗？如果是这样，如何将Mongo DataService用作REST API的资源？

编辑：试图访问服务时，我从Angular2项目中遇到的CORS错误是"在请求的资源上没有''访问对照 - 允许 - 原始'标头。"这是另一个话题。但这导致我编辑了我的数据服务，因此我编辑了我的数据服务资源元素并添加了一个新的：

   <resource method="GET" path="users/count">
   
      <inSequence>
         <property action="set" name="HTTP_SC" scope="axis2" type="STRING" value="200"/>
         <property action="set" name="messageType" scope="axis2" type="STRING" value="application/json"/>
         <sequence key="rest_add_access_control_headers"/>
         <respond/>
      </inSequence>
      <outSequence/>
      <faultSequence>
         <sequence key="rest_add_access_control_headers"/>
         <respond/>
      </faultSequence>
      <call-query href="count"/>
   </resource>
     <resource method="OPTIONS" path="users/count">
       <inSequence>
           <property action="set" name="HTTP_SC" scope="axis2"
               type="STRING" value="200"/>
           <property action="set" name="messageType" scope="axis2"
               type="STRING" value="application/json"/>
           <sequence key="rest_add_access_control_headers"/>
           <respond/>
       </inSequence>
       <outSequence/>
       <faultSequence>
           <sequence key="rest_add_access_control_headers"/>
           <respond/>
       </faultSequence>
   </resource>

rest_add_access_control_headers 序列看起来像这样：

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="rest_add_access_control_headers" xmlns="http://ws.apache.org/ns/synapse">
    <property name="Access-Control-Allow-Origin" scope="transport"
        type="STRING" value="*"/>
    <property name="Access-Control-Allow-Methods" scope="transport"
        type="STRING" value="GET,POST,PUT,DELETE,OPTIONS"/>
    <property name="Access-Control-Allow-Headers" scope="transport"
        type="STRING" value="origin, content-type, accept, Authorization"/>
</sequence>

第一个似乎很好，但第二个使我的数据服务器有故障，在MANAKEMENET控制台中给出了此错误：

DS Code: UNKNOWN_ERROR Source Data Service:- Name: mongodb_dataservice Location: MongoDB.dbs Description: N/A Default Namespace: http://ws.wso2.org/dataservice Nested Exception:- java.lang.NullPointerException at org.wso2.carbon.dataservices.core.DataServiceFactory.createDataService(DataServiceFactory.java:207) at org.wso2.carbon.dataservices.core.DBDeployer.createDBService(DBDeployer.java:797) at org.wso2.carbon.dataservices.core.DBDeployer.processService(DBDeployer.java:1152) at org.wso2.carbon.dataservices.core.DBDeployer.deploy(DBDeployer.java:201) at org.apache.axis2.deployment.repository.util.DeploymentFileData.deploy(DeploymentFileData.java:136) at org.apache.axis2.deployment.DeploymentEngine.doDeploy(DeploymentEngine.java:807) at org.apache.axis2.deployment.repository.util.WSInfoList.update(WSInfoList.java:144) at org.apache.axis2.deployment.RepositoryListener.update(RepositoryListener.java:377) at org.apache.axis2.deployment.RepositoryListener.checkServices(RepositoryListener.java:254) at org.apache.axis2.deployment.RepositoryListener.startListener(RepositoryListener.java:371) at org.apache.axis2.deployment.scheduler.SchedulerTask.checkRepository(SchedulerTask.java:59) at org.apache.axis2.deployment.scheduler.SchedulerTask.run(SchedulerTask.java:67) at org.wso2.carbon.core.deployment.CarbonDeploymentSchedulerTask.runAxisDeployment(CarbonDeploymentSchedulerTask.java:93) at org.wso2.carbon.core.deployment.CarbonDeploymentSchedulerTask.run(CarbonDeploymentSchedulerTask.java:138) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.NullPointerException at org.wso2.carbon.dataservices.core.engine.DataService.init(DataService.java:352) at org.wso2.carbon.dataservices.core.DataServiceFactory.createDataService(DataServiceFactory.java:190) ... 20 more

再次，我不确定我是否应该在数据服务定义中放置此类代码，因为该代码旨在用于REST API定义，即您使用序列，调解器等的代码... p>如何使用ESB API消费数据服务？您能提供有关如何做的示例吗？我做了一些研究，但找不到任何东西。

Answer 1

我可以知道为什么您无法调用数据服务吗？调用时您会遇到任何错误吗？如果您可以提供日志，那将是有帮助的。此外，DSS用于从DB获取数据，最好的做法是提供ESB API，该API会消耗此服务，而不是直接将DSS服务直接传播到外部世界