在 AppSync 中,可以使用 Lambda 函数来执行数据检索,并将结果保存到 DynamoDB 或其他目标数据存储服务中。以下是一个使用 Node.js 实现的简单示例:
// 从数据源获取数据的 Lambda 解析程序 exports.getData = async (event) => { const data = await fetchDataFromSource(); // 假设从某个API获取数据 return { id: data.id, name: data.name, description: data.description }; }
// 保存数据的 Lambda 函数 const AWS = require('aws-sdk'); const dynamoDB = new AWS.DynamoDB.DocumentClient();
exports.saveData = async (data) => { const params = { TableName : 'MyTable', Item: { id: data.id, name: data.name, description: data.description } };
try { const response = await dynamoDB.put(params).promise(); console.log('Data saved successfully:', response); } catch (error) { console.log('Data saved failed:', error); throw new Error('Data saved failed'); } }
完成以上步骤后,您就可以使用 AppSync API 检索和保存数据了。您的 Lambda 函数将负责具体的数据检索和保存功能,而 AppSync 将负责查询语句的输入和输出映射。