平方消费
在没有样板的情况下构建基于SQS的应用程序。 只需定义一个处理SQS消息处理的异步函数即可。
安装
npm install sqs-consumer --save
用法
const { Consumer } = require ( 'sqs-consumer' ) ;
const app = Consumer . create ( {
queueUrl : 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name' ,
handleMessage : async ( message ) => {
// do some work with `message`
}
} ) ;
app . on ( 'error' , ( err ) => {
console . error ( err . message ) ;
} ) ;
app . on ( 'processing_error' , ( err ) => {
console . error ( err . message ) ;
} )
1