AWS Lambda NodeJS: сканирование с дополнительными атрибутами фильтра - PullRequest
Новая
       69

AWS Lambda NodeJS: сканирование с дополнительными атрибутами фильтра

0 голосов
/ 21 февраля 2019

Я создал AWS Lambda, который сканирует и фильтрует мою DynamoDB и возвращает к моему AWS API.Таким образом, у меня было три возможных параметра поиска (имя элемента, автор и тип), тогда как я не знаю, какие из них используются в запросе.Сначала я реализовал версию, в которой все параметры поиска жестко заданы.В результате я получил ошибки, если не все параметры поиска были определены.В конце я переработал код для создания отдельных параметров сканирования в зависимости от введенного параметра поиска.

Код работает нормально, но я думаю, что есть более эффективные реализации для этой проблемы, возможно, вы можете дать мне несколько советов по улучшению,В противном случае это поможет людям, которые сталкиваются с такими же проблемами, с их дополнительными параметрами поиска. 

var AWS = require('aws-sdk');
var docClient = new AWS.DynamoDB.DocumentClient();

//This is the Lambda function
exports.handler = function(event, context, callback) 
{
//In case we query without query attributes
if(!event.hasOwnProperty("queryStringParameters"))
        {
            console.log("NO queryStringParameters FOUND");
            var emptyparams = 
                {  
                    TableName: "blackboard-items",
                };
            docClient.scan(emptyparams, onScan);
            return;
        }
        
//we want to tailor this attributes for the params for docClient.scan(params, onScan); 
var queryParam = event["queryStringParameters"];
var filterexpression = "";
var expressionAttributeNames = {}; //Instantiate
var expressionAttributeValues = {};
console.log("QUERY PARAMETERS: " + JSON.stringify(queryParam));
    
//Do we look for an author?
if(queryParam.hasOwnProperty("author"))
    {
        console.log("FOUND AUTHOR");
        filterexpression += "contains(#author, :author)"; //Collect scan params
        expressionAttributeNames['#author'] = 'author';
        expressionAttributeValues[':author'] = event["queryStringParameters"]["author"];
    }
    
//Do we look for an itemname?
if(queryParam.hasOwnProperty("itemname"))
    {
    console.log("FOUND ITEMNAME");
    if(filterexpression !== "")
        filterexpression += " AND contains(#itemname, :itemname)";
    else
        filterexpression += "contains(#itemname, :itemname)";
        
    expressionAttributeNames['#itemname'] = 'itemname';
    expressionAttributeValues[':itemname'] = queryParam["itemname"];    
    }
    
//Do we look for a type?
if(queryParam.hasOwnProperty("type"))
    {
    console.log("FOUND TYPE");
    if(filterexpression !== "")
        filterexpression += " AND #type = :type";
    else
        filterexpression += "#type = :type";
        
    expressionAttributeNames['#type'] = 'type';
    expressionAttributeValues[':type'] = event["queryStringParameters"]["type"]; 
    }
  
//Build params based on the tailored parts
var params = 
    {  
        TableName: "blackboard-items",
        FilterExpression: filterexpression,
        ExpressionAttributeNames: expressionAttributeNames,
        ExpressionAttributeValues: expressionAttributeValues,
    };
  
//Use tailored params for scan()
docClient.scan(params, onScan);
var count = 0;

function onScan(err, data)
    {
       if (err) 
        {
        console.error("Unable to scan the table. Error JSON:", JSON.stringify(err, null, 2));
        } 
        else 
        {        
        console.log("Scan succeeded.");
        data.Items.forEach(function(itemdata) 
            {
               console.log("Item :", ++count,JSON.stringify(itemdata));
            });

            // continue scanning if we have more items
            if (typeof data.LastEvaluatedKey != "undefined") 
            {
                console.log("Scanning for more...");
                params.ExclusiveStartKey = data.LastEvaluatedKey;
                docClient.scan(params, onScan);
            }
        }
        
        
    var response = 
    {
    "isBase64Encoded": false,
    "statusCode": "200",
    "headers": {  },
    "body": JSON.stringify(data.Items)
    };
 
    callback(null, response);
        
    }
 };

Примечание. Первичным ключом БД является «itemname», но я скоро переделаю дизайн БД, чтобы получить ключ сортировки.

1 Ответ

0 голосов
/ 21 февраля 2019

DynamoDB очень ограничен в своих возможностях запроса, и поэтому вы должны избегать scan любой ценой.Каждая операция сканирования будет потреблять ваши RCU для каждого элемента, который он читает.Если в вашей таблице много элементов, она может довольно быстро израсходовать ваши RCU.

Если вы хотите выполнить запрос по этим 3 атрибутам, то DynamoDB может оказаться не лучшей базой данных для вашего варианта использования.Если вместо этого вы можете сузить запрос до 1 атрибута за раз, вы можете использовать Глобальные вторичные индексы .Таким образом, вы можете запросить на основе автора или типа.Вы можете увидеть этот ответ о том, как запрашивать GSI в DynamoDB

...