Simple Queue service(SQS) 在設計系統時, 若不希望元件之間相依程度過高的話, 通常會在元件之間加一層message queue來解偶 在雲上, AWS提供的Simple Queue Service 簡稱SQS, 讓我們可以把雲上各個相依的服務元件解偶, 進而提升整體系統的延展性 Key Feature Pull Based 不會自動推撥訊息, consumer 需要不斷地去詢問有沒有可執行的任務在佇列中 (2018年六月之後的SQS可以透過事件來驅動Lambda) 訊息大小 目前支援最大256kb 訊息的保存期限 最短1分鐘到最長14天, 訊息一旦過保就會被刪除 訊息的存取時間 預設每則訊息可以被獨佔30秒, 因為當訊息被截取之後, 會變成隱蔽狀態, 可是一旦超過這個存取時間之後, 狀態會恢復, 重新開放給任何其他的consumer去獨佔, 當然我們也可以延長獨佔的時間到最長12小時 存取的範例程式碼 var params = { AttributeNames: [ "SentTimestamp" ], MaxNumberOfMessages: 1 , MessageAttributeNames: [ "All" ], QueueUrl: queueURL, VisibilityTimeout: 2 , //訊息的存取時間 WaitTimeSeconds: 0 //等待回復的時間, 設為0表示Short polling }; sqs.receiveMessage(params, (err,data)=>{ if (err){ console.log(err); } else { console.log( "Received Data:" ,data); } }) 任務完成後必須要手動清掉佇列中的訊息, 否則當存取時間超過之後, 訊息會重新開放給其他的consumer, ...
發表文章
Lambda Function 如何呼叫另一個 Lambda Function? 實務上有些情況我們會需要從某個Lambda function去呼叫另一個Lambda function起來做事 例如, 處理客戶訂單的OrderLambdaFunction 處理完客戶訂購的請求後, 需要喚起處理付款的PaymentLambdaFunction 要達到這個目的有兩個方法 Lambda Invoke 這個方法最簡單, 使用aws-sdk就能呼叫另一個Lambda Function, 但我們需要添加合適的Policy到OrderLambdaFunction使用的Role中 { "Sid": "Stmt1234567890", "Effect": "Allow", "Action": [ "lambda:InvokeFunction" ], "Resource": "*" } 步驟1: IAM > Policies > Create Policy > JSON(建立Customized Policy) 步驟2: IAM > Roles > Your_Lambda_Role > Attach Policy OrderLambdaFunction exports.handler = (event, context, callback) => { // TODO implement lambda.invoke({ FunctionName: 'PaymentLambdaFunction', Payload: JSON.stringify({}, null, 2) // pass params }, function(error, data) { if (error) { console.log(...
When we create an alexa skill, we have to specify intent, utterance, and slot(optional).These are called interaction model in alexa skill interface. For example, if we create a skill that provides information of repair center, we can define the interaction model like this: { "intents":[ "name" : GetRepairCenter, "samples": where is the repair center in New York "slots": [ { "name": "location", ...