node.js - 使用 NodeJS 发送基于 DynamoDb 流的 graphQL 突变

Question

当 DynamoDb 表收到新行时，我正在尝试更新 GraphQL 订阅。我得到的以下代码仅适用于 RekognitionId，但我并没有尝试发送整个 NewImage 对象，而且我无法使其工作。我遇到了各种各样的类型问题，但没有真正的信息来解决它。最能说明问题的是:
"Error: GraphQL error: Variable 'input' has an invalid value. Expected type 'Map' but was 'String'. Variables for input objects must be an instance of type 'Map'."
不幸的是，我找不到对称为“map”的 GraphQL 类型的单个引用，因此它可能被打乱了。

有没有人有这方面的经验？这是我的 Lambda 函数，就像我说的，它只适用于格式化为 dynamoDb 半 json 字符串的 RekognitionId {"S": "id"}

global.WebSocket = require('ws');
require('es6-promise').polyfill();
require('isomorphic-fetch');
const AWS = require('aws-sdk');
const aws_exports = require('./aws-exports').default;
const AWSAppSyncClient = require('aws-appsync').default;

exports.handler = async (event, context, callback) => {
    if(!event.Records.length){
        console.log('no records');
        return false;
    }
    const AUTH_TYPE = require('aws-appsync/lib/link/auth-link').AUTH_TYPE;
    const url = aws_exports.ENDPOINT;
    const region = aws_exports.REGION;
    const type = AUTH_TYPE.AMAZON_COGNITO_USER_POOLS;

    AWS.config.update({
        region: aws_exports.REGION,
        credentials: new AWS.Credentials({
            accessKeyId: aws_exports.AWS_ACCESS_KEY_ID,
            secretAccessKey: aws_exports.AWS_SECRET_ACCESS_KEY
        })
    });
    const cognitoIdentityServiceProvider = new AWS.CognitoIdentityServiceProvider({ apiVersion: '2016-04-18' });

    const initiateAuth = async ({ clientId, username, password }) => cognitoIdentityServiceProvider.initiateAuth({
        AuthFlow: 'USER_PASSWORD_AUTH',
        ClientId: clientId,
        AuthParameters: {
            USERNAME: username,
            PASSWORD: password,
        },
    }).promise();
    const { AuthenticationResult } = await initiateAuth({
        clientId: '*******',
        username: '*******',
        password: '*******',
    });
    const accessToken = AuthenticationResult && AuthenticationResult.AccessToken;

    // Import gql helper and craft a GraphQL query
    const gql = require('graphql-tag');
    const query = gql(`
    mutation faceAdded($input: UpdateFaceInput!) {
        updateFace(input: $input) { 
            RekognitionId
            Emotions {
                Confidence
                Type
            }
            AgeRange
            Beard
            Mustache
            Gender
            Eyeglasses
        }
    }`);
    // Set up Apollo client
    const client = new AWSAppSyncClient({
        url: url,
        region: region,
        auth: {
            type: type,
            jwtToken: accessToken,
        },
        disableOffline: true      //Uncomment for AWS Lambda
    });
    return runMutationInClient(client, query, event.Records[0], (res) => {
        return res;
    });
}

const runMutationInClient = async (client, query, RekognitionObj, callback) => {
    await client.hydrated().then( async (client) => {
        console.log('Running mutation in Lambda: ', query, 'RekognitionId: ', RekognitionObj);

        var inputObj = AWS.DynamoDB.Converter.unmarshall(RekognitionObj.dynamodb.NewImage)

        await client.mutate({
            mutation: query,
            variables: {
                input: {
                    RekognitionId: {"S": inputObj.RekognitionId},
                    Emotion: {"L": []}
                }
            },
            fetchPolicy: 'no-cache'
        }).then(function logData(data) {
            console.log('LAMBDA results of query: ', data);
            callback(data);
        })
        .catch((error)=>{
            console.log('LAMBDA ERROR:', error);
            callback(error);
        });

    });
};

Answer 1

我经常看到这个错误(可悲的是!)，它的措辞很糟糕，因为它没有提到映射我们可能思考的方式。错误是您的 graphql 连接字符串格式错误或缺少关键数据。
有两种解决方案。第一种是在某种类型的沙箱中试用 graphql。 AWS Amplify 和 Apollo 都在控制台中提供了它们。在 AWS 的情况下，您还可以模拟您的数据库并在您的机器上运行它 - 尽管您需要在模拟环境中创建一些数据 - 如果您在本地机器上作为两组数据进行开发，则在继续之前清除它- 真实和模拟交织在一起!是的，在那一个上浪费了几个小时!
另一种解决方案是简单地控制台输出数据字符串，无论您在查询中依赖什么数据以确保数据存在。偶尔看起来一切都很好，但是当数据丢失时往往会发生这种错误。
您可以测试数据。取好数据串再刻意取所需! element out 或其他，你会在某个时候得到映射错误。这是指graphql无法映射数据，而不是map的javascript含义。