2015-10-30 3 views
2

Я нахожусь в месте, где я слишком часто встречаюсь с AWS. Я выясняю, как использовать рабочее приложение в Elastic Beanstalk. У меня есть приложение, настроенное для прослушивания сообщения. Я помещаю сообщение в свою очередь SQL. Я получаю что-то в узле, так как я могу вызвать сообщение. Но я не знаю, как добраться до полезной нагрузки. Как обычно, я, кажется, остаюсь хвататься за AWS, пытаясь собрать самые основные детали из документации. Если кто-нибудь может дать мне какие-либо указания, я буду очень благодарен. В данный момент я просто вставляю JSON в тело сообщения на консоли AWS SQS. Я попробовал request.body и request.payload на стороне узла - ничего.AWS Beanstalk Worker - Node.js Формат сообщения

Это запрос, который попадает в момент поступления данных - это довольно просто. Должен быть помещен в журнал. Я пробовал request.body, request.params, я получил «undefined». Здесь я выгрузил весь объект запроса, и я не вижу его. Поскольку я не знаю, где это должно быть, я не могу даже сказать, является ли это моим кодом, или его просто нет.

var stringify = require('json-stringify-safe'); 

function test(request, response, next) 
{ 

    mainLog.log("info",stringify(request)); 

    respond_to_HTTP_request(response, null, null);; 
} 
exports.test = test; 
+0

Можете ли вы АКЦИЮ код, который вы используете для обработки сообщений SQS? – James

+0

Я не. Если я не полностью запутался, вы настроите конечную точку HTTP, используя что-то вроде Express. Существует настройка конфигурации в Beanstalk, где вы указываете, что такое локальная конечная точка. Итак, если я не понимаю этого правильно, и я должен настроить его для обработки сообщения SQS, это будет моей проблемой. Но это не то, о чем свидетельствует документация. – CargoMeister

+0

Нет, вы правильно поняли. Не могли бы вы поделиться кодом, который используете, чтобы обрабатывать HTTP-сообщения, поступающие из утилиты sqsd, которая извлекает сообщения из очереди SQS? – James

ответ

1
var bodyParser = require('body-parser'); 
app.use(bodyParser.json()); 
+0

Добавление объяснения того, как этот код отвечает на вопрос, улучшит ваш ответ для будущих посетителей (этот ответ был отмечен как некачественный). – JAL

0

Установка и настройка модуля тела синтаксического анализатора:

var bodyParser = require('body-parser'); app.use(bodyParser.json());

тогда ваша полезная нагрузка будет доступна в вашей функции:

var payload = request.body;