Бессерверная разработка с Node.js, AWS Lambda и MongoDB Atlas

Кроме того, если вы не используете пиринг VPC, перейдите на вкладку «Белый список IP-адресов » и добавьте блок CIDR 0.0.0.0/0 или нажмите кнопку « Разрешить доступ из любого места» . Напоминаем, что этот параметр настоятельно НЕ рекомендуется для производственного использования и потенциально делает ваш кластер MongoDB Atlas уязвимым для злонамеренных атак.

Создать локальный проект Node.js

Хотя лямбда-функции поддерживаются на нескольких языках, я решил использовать Node.js благодаря растущей популярности JavaScript в качестве универсального языка программирования и огромному успеху стеков MEAN и MERN (сокращений для M ongoDB, E xpress.js, Angular / R eact, N ode.js — ознакомьтесь с отличной серией блогов Эндрю Моргана, посвященной разработчикам на эту тему). Плюс, если честно, мне нравится тот факт, что это интерпретированный, легкий язык, который не требует тяжелых инструментов разработки и компиляторов.

Пришло время написать некоторый код, так что давайте продолжим и будем использовать Node.js в качестве нашего предпочтительного языка для нашей функции Lambda.

Начните с создания папки, такой как lambda-atlas-create-doc

 mkdir lambda-atlas-create-doc && cd lambda-atlas-create-doc 

Затем выполните следующую команду из консоли терминала, чтобы инициализировать наш проект с файлом package.json.

 npm init 

Вам будет предложено настроить несколько полей. Я оставлю их на ваше усмотрение, но учтите, что я решил установить точку входа app.js (вместо index.js по умолчанию), так что вы можете захотеть сделать то же самое.

Нам потребуется использовать драйвер MongoDB Node.js, чтобы мы могли подключиться к нашей базе данных MongoDB (в Atlas) из нашей функции Lambda, поэтому давайте продолжим и установим ее, выполнив следующую команду из корня нашего проекта:

 npm install mongodb --save 

Мы также хотим написать и протестировать нашу лямбда-функцию локально, чтобы ускорить разработку и упростить отладку, поскольку создание лямбда-функции каждый раз в Amazon Web Services не особенно быстро (а отладка практически отсутствует, если только вы не фанат функции console.log() ). Я решил использовать пакет lambda-local, потому что он обеспечивает поддержку переменных среды (которые мы будем использовать позже):

 (sudo) npm install lambda-local -g 

Создайте файл app.js Это будет файл, который содержит нашу лямбда-функцию:

 touch app.js 

Теперь, когда вы импортировали все необходимые зависимости и создали файл кода Lambda, откройте файл app.js в выбранном вами редакторе кода (Atom, Sublime Text, Код Visual Studio …) и инициализируйте его следующим фрагментом кода:

 'use strict' var MongoClient = require('mongodb').MongoClient; let atlas_connection_uri; let cachedDb = null; exports.handler = (event, context, callback) => { var uri = process.env['MONGODB_ATLAS_CLUSTER_URI']; if (atlas_connection_uri != null) { processEvent(event, context, callback); } else { atlas_connection_uri = uri; console.log('the Atlas connection string is ' + atlas_connection_uri); processEvent(event, context, callback); } }; function processEvent(event, context, callback) { console.log('Calling MongoDB Atlas from AWS Lambda with event: ' + JSON.stringify(event)); } 

Давайте сделаем небольшую паузу и прокомментируем приведенный выше код, поскольку вы могли заметить несколько своеобразных конструкций:

• Файл написан точно так же, как и лямбда-код, который ожидает Amazon Web Services (например, с функцией export.handler). Это потому, что мы используем lambda-local для локального тестирования нашей лямбда-функции, что позволяет нам писать наш код именно так, как его ожидает AWS Lambda. Подробнее об этом через минуту.
• Мы объявляем драйвер MongoDB Node.js, который поможет нам подключиться и выполнить запрос к нашей базе данных MongoDB.
• Также обратите внимание, что мы объявляем объект cachedDb ВНЕ от функции-обработчика. Как следует из названия, это объект, который мы планируем кэшировать на время работы базового контейнера, который AWS Lambda создает для нашей функции. Это позволяет нам сэкономить драгоценные миллисекунды (и даже секунды) для создания соединения с базой данных между Lambda и MongoDB Atlas. Для получения дополнительной информации, пожалуйста, прочитайте мой следующий пост в блоге о том, как оптимизировать производительность Lambda с помощью MongoDB Atlas .
• Мы используем переменную окружения под названием MONGODB_ATLAS_CLUSTER_URI для передачи строки соединения uri нашей базы данных Atlas, главным образом в целях безопасности: очевидно, мы не хотим жестко кодировать этот uri в нашем коде функции вместе с очень конфиденциальной информацией, такой как имя пользователя и пароль мы используем. Так как AWS Lambda поддерживает переменные среды с ноября 2016 года (как это делает пакет lambda-local NPM), мы бы не стали их использовать.
• Код функции выглядит немного запутанным с, казалось бы, бесполезным оператором if-else и функцией processEvent, но все это станет понятным, когда мы добавим подпрограммы дешифрования с использованием AWS Key Management Service (KMS). Действительно, мы не только хотим сохранить нашу строку подключения MongoDB Atlas в переменной среды, но мы также хотим зашифровать ее (используя AWS KMS), поскольку она содержит высокочувствительные данные (обратите внимание, что при использовании AWS KMS могут возникать дополнительные расходы). если у вас есть бесплатный аккаунт AWS).

Теперь, когда мы закончили с комментариями к коду, давайте создадим файл event.json (в корневом каталоге проекта) и заполните его следующими данными:

 { "address" : { "street" : "2 Avenue", "zipcode" : "10075", "building" : "1480", "coord" : [ -73.9557413, 40.7720266 ] }, "borough" : "Manhattan", "cuisine" : "Italian", "grades" : [ { "date" : "2014-10-01T00:00:00Z", "grade" : "A", "score" : 11 }, { "date" : "2014-01-16T00:00:00Z", "grade" : "B", "score" : 17 } ], "name" : "Vella", "restaurant_id" : "41704620" } 

 lambda-local -l app.js -e event.json -E {\"MONGODB_ATLAS_CLUSTER_URI\":\"mongodb://lambdauser:$PASSWORD@lambdademo-shard-00-00-7xh42.mongodb.net:27017\,lambdademo-shard-00-01-7xh42.mongodb.net:27017\,lambdademo-shard-00-02-7xh42.mongodb.net:27017/$DATABASE?ssl=true\&replicaSet=lambdademo-shard-0\&authSource=admin\"} 

 function processEvent(event, context, callback) { console.log('Calling MongoDB Atlas from AWS Lambda with event: ' + JSON.stringify(event)); var jsonContents = JSON.parse(JSON.stringify(event)); //date conversion for grades array if(jsonContents.grades != null) { for(var i = 0, len=jsonContents.grades.length; i connecting to database'); MongoClient.connect(atlas_connection_uri, function (err, db) { cachedDb = db; return createDoc(db, jsonContents, callback); }); } else { createDoc(cachedDb, jsonContents, callback); } } catch (err) { console.error('an error occurred', err); } } function createDoc (db, json, callback) { db.collection('restaurants').insertOne( json, function(err, result) { if(err!=null) { console.error("an error occurred in createDoc", err); callback(null, JSON.stringify(err)); } else { console.log("Kudos! You just created an entry into the restaurants collection with id: " + result.insertedId); callback(null, "SUCCESS"); } //we don't need to close the connection thanks to context.callbackWaitsForEmptyEventLoop = false (above) //this will let our function re-use the connection on the next called (if it can re-use the same Lambda container) //db.close(); }); }; 

 zip -r archive.zip node_modules/ app.js package.json 

 const AWS = require('aws-sdk'); 

 const kms = new AWS.KMS(); kms.decrypt({ CiphertextBlob: new Buffer(uri, 'base64') }, (err, data) => { if (err) { console.log('Decrypt error:', err); return callback(err); } atlas_connection_uri = data.Plaintext.toString('ascii'); processEvent(event, context, callback); });