AWS Kinesis 服務用于捕獲/存儲來自網(wǎng)站點擊、日志、社交媒體源的實時跟蹤數(shù)據(jù)。我們可以觸發(fā) AWS Lambda 對這些日志執(zhí)行額外的處理。

要求

開始使用 Kinesis 和 AWS Lambda 的基本要求如下所示-

創(chuàng)建具有所需權限的角色在 Kinesis 中創(chuàng)建數(shù)據(jù)流創(chuàng)建 AWS Lambda 函數(shù)。向 AWS Lambda 添加代碼將數(shù)據(jù)添加到 Kinesis 數(shù)據(jù)流

示例

讓我們研究一個示例，在該示例中我們將觸發(fā) AWS Lambda 來處理來自 Kinesis 的數(shù)據(jù)流，并使用收到的數(shù)據(jù)發(fā)送郵件。

用于解釋該過程的簡單框圖如下所示-

創(chuàng)建具有所需權限的角色

轉到 AWS 控制臺并創(chuàng)建角色。

在 Kinesis 中創(chuàng)建數(shù)據(jù)流

轉到 AWS 控制臺并在 kinesis 中創(chuàng)建數(shù)據(jù)流。

如圖所示有 4 個選項。我們將在本例中創(chuàng)建數(shù)據(jù)流。

點擊 創(chuàng)建數(shù)據(jù)流。在下面給出的 Kinesis 流名稱中輸入名稱。

輸入數(shù)據(jù)流的分片數(shù)。

Shards 的詳細信息如下所示-

輸入名稱并點擊底部的 創(chuàng)建 Kinesis 流按鈕。

請注意，流激活需要一定的時間。

創(chuàng)建 AWS Lambda 函數(shù)

轉到 AWS 控制臺并單擊 Lambda。創(chuàng)建 AWS Lambda 函數(shù)，如圖所示-

點擊屏幕末尾的 創(chuàng)建函數(shù)按鈕。將 Kinesis 作為觸發(fā)器添加到 AWS Lambda。

向 Kinesis 觸發(fā)器添加配置詳細信息-

添加觸發(fā)器，現(xiàn)在將代碼添加到 AWS Lambda。

向 AWS Lambda 添加代碼

為此，我們將使用 nodejs 作為運行時。使用 Kinesis 數(shù)據(jù)流觸發(fā) AWS Lambda 后，我們將發(fā)送郵件。

const aws =  require("aws-sdk");
var ses = new aws.SES({
   region: "us-east-1"
});
exports.handler = function(event, context, callback) {
   let payload = "";
   event.Records.forEach(function(record) {
      // Kinesis data is base64 encoded so decode here
      payload = new Buffer(record.kinesis.data, "base64").toString("ascii");
      console.log("Decoded payload:", payload);
   });
   var eParams = {
      Destination: {
         ToAddresses: ["xxxxxxx@gmail.com"]
      },
      Message: {
         Body: {
            Text: {
               Data:payload
            }
         },
         Subject: {
            Data: "Kinesis data stream"
         }
      },
      Source: "cxxxxxxxxx@gmail.com"
   };    
   var email = ses.sendEmail(eParams, function(err, data) {
      if (err) console.log(err);
      else {
         console.log("===EMAIL SENT===");
         console.log("EMAIL CODE END");
         console.log("EMAIL: ", email);
         context.succeed(event);
         callback(null, "email is send");
      }
   });
};

事件參數(shù)具有輸入到 kinesis 數(shù)據(jù)流中的數(shù)據(jù)。一旦將數(shù)據(jù)輸入到 kinesis 數(shù)據(jù)流中，上述 aws lambda 代碼將被激活。

將數(shù)據(jù)添加到 Kinesis 數(shù)據(jù)流

這里我們將使用 AWS CLI 添加數(shù)據(jù) kinesis 數(shù)據(jù)流，如下所示。為此，我們可以使用以下命令-

aws kinesis put-record--stream-name kinesisdemo --data "hello world"--
partition-key "789675"

然后，AWS Lambda 被激活并發(fā)送郵件。

作為AWS頂級代理商，選擇天.下.數(shù).據(jù)的優(yōu)勢

1、專屬客服協(xié)助注冊AWS，或提供注冊好的賬號直接使用

2、支持收U等多幣種支付代付，無額外服務費用

3、AWS多種產(chǎn)品類型，更高產(chǎn)品租賃權限

4、針對大客戶，AWS專屬折扣優(yōu)惠

5、7x24小時專屬客服，在線解答各種疑問

詳詢電話40 0-63 8-88 08 官網(wǎng)：http://m.51huadong.com/2023/aws.asp

本文鏈接：http://m.51huadong.com/cloundnews/11008962.html