2017-08-17 2 views
0

J'ai créé un exemple d'application dans lequel je lis des messages provenant de la file d'attente AWS SQS. Fifo si c'est important, mais je doute. J'ai réussi à obtenir le corps du message et à l'écrire en DB, mais je ne vois pas où sont les autres informations, comme les attributs? Étant dans un travailleur env connecté à la file d'attente, lorsqu'un nouveau message est créé, l'application est appelée via POST, donc j'utilise req.on('data', function (chunk){...}. 'Chunk' contient la chaîne de corps (en tant que tampon en fait)AWS.SQS: Comment puis-je obtenir les attributs d'un message dans un environnement de travail EB (Node.js)

Comment puis-je trouver l'attribut personnalisé? Une idée?

Répondre

0

J'ai trouvé la réponse. Je l'affiche ici au cas où quelqu'un d'autre en aurait besoin.

Le req.headers contient:

{ host: 'localhost', 
    'x-real-ip': '127.0.0.1', 
    'x-forwarded-for': '127.0.0.1', 
    'content-length': '13', 
    'content-type': 'application/json', 
    'user-agent': 'aws-sqsd/2.3', 
    'x-aws-sqsd-msgid': 'dbba278c-0463-47e4-a718-54c86dd004e0', 
    'x-aws-sqsd-receive-count': '1', 
    'x-aws-sqsd-first-received-at': '2017-08-17T18:18:45Z', 
    'x-aws-sqsd-sent-at': '2017-08-17T18:18:45Z', 
    'x-aws-sqsd-queue': 'queue1.fifo', 
    'x-aws-sqsd-path': '', 
    'x-aws-sqsd-sender-id': '...your-id....', 
    'x-aws-sqsd-attr-<atribute name>': '<atribute value>' }