将AWS Appsync与AWS Neptune一起使用

Question

我目前正在使用Aws Appsync、Aws Lambda和Aws Neptune作为应用程序。我的Lambda函数使用NodeJS 12。现在我的问题是，当我执行一个变异并最终执行一个查询时，从Neptune（更具体地说是gremlin）那里为我的graphql api（appsync）获取适当的JSON格式（我想确保变异首先起作用）。例如：

1. 这是我的图ql模式的Post类型，上面有addPost突变：Post模式
2. addPost突变映射到这个解析器：后突变解析器
3. 然后运行这段代码：Lambda Code

当我运行这个测试查询来添加帖子时，我得到以下错误，数据为null：addPost测试查询和结果

在gremlin中添加顶点是否返回数据/对象？如果是，如何为我的appsync graphql api获取适当的JSON格式？我一直在阅读《实用小精灵》并在网上搜索，但运气不好。提前谢谢你。

Answer 1

您看到的很可能与Lambda与节点的默认返回格式不兼容有关。js GLV。返回的默认格式是GraphSONV3，它类似于JSON，但不是格式良好的JSON。Lambda需要格式良好的JSON。在建立与海王星的连接时，可以更改mimetype以使用GraphSONV2，Lambda应该不会有任何问题。

const dc = new DriverRemoteConnection(
  `wss://<neptune-endpoint>:8182/gremlin`,
  { mimeType: "application/vnd.gremlin-v2.0+json" } 
);

另一件需要验证的事情是如何解决等待的Gremlin查询返回的promise。在示例代码中，您似乎将等待查询的结果输入JSON。stringify（）。我认为这行不通，因为这将有效地返回Promise的JSON字符串化版本（这就是您所看到的）。在这种情况下（如果您想异步提交查询），您可以做的是将您的Gremlin查询（或者甚至这个更大的case语句）放入Lambda处理程序之外的异步函数中。例子：

const gremlin = require('gremlin');
const DriverRemoteConnection = gremlin.driver.DriverRemoteConnection;
const Graph = gremlin.structure.Graph;

const dc = new DriverRemoteConnection('wss://<neptune-endpoint>:8182/gremlin',
    { mimeType: "application/vnd.gremlin-v2.0+json" }
    );

const graph = new Graph();
const g = graph.traversal().withRemote(dc);

async function callNeptune() {
    const result = await g.addV('Post').property('userId','someid').
        property('genre','somegenre').
        property('caption','somecaption').
        property('timestamp','sometimestamp').
        toList();
    console.log(result);
    dc.close();
    try {
        return result;
    } catch (error) {
        return error;
    }
}

exports.handler = async (event) => {

    const rawOutput = await callNeptune();
    const jsonOutput = JSON.stringify(rawOutput);
    const response = {
        statusCode: 200,
        body: jsonOutput,
    };
    return response;
};

在这个场景中，您正在通过处理程序中的等待调用等待Gremlin查询的异步函数。因此，您可以从中获取结果并将其输入JSON。Stringify（）并返回它。Lambda服务将在此时解析处理程序的promise。

FWIW，从Lambda支持的API层到Neptune使用async/wait几乎没有好处。Lambda函数和Neptune服务器端线程都将等待（并占用资源），直到所有promise都得到解决。在许多情况下，这只会增加仅使用同步调用的复杂性。如果您从长期运行的容器化应用程序或基于Web的前端执行此操作，情况会有所不同，在此期间让其他进程有意义。