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

要求

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

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

示例

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

用于解釋該過程的簡(jiǎn)單框圖如下所示-

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

轉(zhuǎn)到 AWS 控制臺(tái)并創(chuàng)建角色。

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

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

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

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

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

Shards 的詳細(xì)信息如下所示-

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

請(qǐng)注意，流激活需要一定的時(shí)間。

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

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

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

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

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

向 AWS Lambda 添加代碼

為此，我們將使用 nodejs 作為運(yùn)行時(shí)。使用 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頂級(jí)代理商，選擇天.下.數(shù).據(jù)的優(yōu)勢(shì)

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

2、支持收U等多幣種支付代付，無額外服務(wù)費(fèi)用

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

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

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

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

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