如果選擇新流程dmhc_flow并按下Run flow按鈕，所有數(shù)據(jù)將插入 Honeycode 應(yīng)用程序dmhc_data_table，每 5 分鐘更新一次。

在手機(jī)的 Honeycode 應(yīng)用程序中打開應(yīng)用程序 DMHC 數(shù)據(jù)表，將看到紅色背景中的所有數(shù)據(jù)和一些警報(bào)。

?

?

?

?

1 / 3 ?手機(jī)中的 DMHC 數(shù)據(jù)表應(yīng)用程序

?

亞馬遜 QuickSight

借助 Amazon QuickSight，我們可以分析和創(chuàng)建連接到 AWS IoT Analytics 數(shù)據(jù)集的數(shù)據(jù)儀表板。

我們可以從大量數(shù)據(jù)源、數(shù)據(jù)庫和 AWS 服務(wù)中創(chuàng)建數(shù)據(jù)集。

• 選擇datasets, New dataset,
• 搜索AWS IoT Analytics，
• 選擇dmhc_host_dataset，創(chuàng)建源，它會(huì)顯示一個(gè) Spice 數(shù)據(jù)集。

打開它，可以看到所有的香料信息，并可以刷新或安排自動(dòng)刷新率。

?

?

?

?

1 / 5 ?創(chuàng)建數(shù)據(jù)集

?

創(chuàng)建數(shù)據(jù)集后，我們需要?jiǎng)?chuàng)建一個(gè)分析來處理香料中的所有數(shù)據(jù)。

• 創(chuàng)建分析dmhc_host_analyses
• S選擇香料dmhc_host_dataset
• 添加兩種視覺類型line chart
• 添加 和 的字段X axis，Values請(qǐng)參見下圖。
• 選擇Share 并Publish Dashboard創(chuàng)建儀表板DMHC HOST Probe。

?

?

?

?

1 / 5 ?創(chuàng)建分析 dmhc_host_analysiss

?

如果選擇創(chuàng)建的儀表板，您可以在瀏覽器中看到它

?

?

?

?

1 / 2 ?瀏覽器中的儀表板

?

在手機(jī)中打開 QuickSight 應(yīng)用程序，將看到創(chuàng)建的儀表板。

?

?

?

?

1 / 5 ? Aws QuickSight - 收藏夾

?

亞馬遜時(shí)間流和 Grafana

Grafana 是另一種用于創(chuàng)建圖形和儀表板的工具，并且有一個(gè)用于 Amazon Timestream 的插件。您可以連接到數(shù)據(jù)庫和表并分析數(shù)據(jù)時(shí)間序列，

我們需要用戶憑證訪問密鑰 ID 和秘密訪問密鑰，以便 Grafana 訪問數(shù)據(jù)庫和表。

AWS IAM

• 選擇Users,Add user
• 用戶名：dmhc_timestreamuser
• 選擇 AWS 憑證類型：Access key - Programmatic access
• 添加策略：AmazonTimestreamFullAccess
• 保存Access Key ID并Secret access key

在https://grafana.com/創(chuàng)建您的帳戶

• 登錄到您的工作區(qū)
• 選擇Configuration并Plugins 添加Amazon Timestream plugin
• 選擇Configuration，Datasources點(diǎn)擊亞馬遜時(shí)間流
• 更新Access Key ID并Secret Access Key從dmhc_timestreamuser創(chuàng)建
• 默認(rèn)區(qū)域：us-west-2
• If憑據(jù)沒問題，您可以選擇數(shù)據(jù)庫dmhc_timestreamdb和表dmhc_timestreamtable
• 按保存并測(cè)試

?

?

?

?

1 / 2 ? Grafana 配置插件

?

• 選擇 + 創(chuàng)建，儀表板
• 添加空面板，將其重命名為 DHMC HOST
• 設(shè)置數(shù)據(jù)源 Amazon Timestream
• 為每個(gè)值添加三個(gè)查詢

SELECT CREATE_TIME_SERIES(time,measure_value::bigint) as temperature FROM $__database.$__table where $__timeFilter and measure_name = 'temperature'

SELECT CREATE_TIME_SERIES(time,measure_value::bigint) as spo2 FROM $__database.$__table where $__timeFilter and measure_name = 'spo2'

SELECT CREATE_TIME_SERIES(time,measure_value::bigint) as heartrate FROM $__database.$__table where $__timeFilter and measure_name = 'heartrate'

Grafana 新儀表板和三個(gè)查詢

?

按保存并應(yīng)用，您現(xiàn)在可以在儀表板中看到所有數(shù)據(jù)值。

?

?

?

?

1 / 2 ?瀏覽器中的 Grafana 儀表板

?

?

Amazon EventBridge、Amazon SNS、AWS Chatbot 和 Amazon Pinpoint

為了控制 DMHC HOST Probe 請(qǐng)求運(yùn)行狀況檢查的頻率，我們將使用Amazon EventBridge將調(diào)用 Lambda 函數(shù)的服務(wù)，dmhc_ResetDevice以便它使用AWS IoT Core主題向設(shè)備發(fā)送通知 MQTT，該主題dmhc/reset將告訴您重新啟動(dòng)并繼續(xù)捕獲新數(shù)據(jù)。

• 拉姆達(dá)函數(shù)：dmhc_ResetDevice
• 語言：Node.js 14.x
• 部分代碼處的源代碼
• 設(shè)置角色和權(quán)限：AWSIoTFullAccess和AmazonSNSFullAccess
Change
• 更改 lambda 函數(shù)PhoneNume 中的 SMS 參數(shù)：xxxxxxxx您的注冊(cè)電話號(hào)碼，請(qǐng)參閱 AWS PinPoint 部分。

var AWS = require('aws-sdk');

// Define object AWS IoT Core with endpoint
var iotdata = new AWS.IotData({endpoint: 'a2i2bsijbyml6j-ats.iot.us-west-2.amazonaws.com' });
// Define object AWS SNS for SMS and Slack notifications
var sns = new AWS.SNS();

//Call by AWS EventBridge
exports.handler = async(event, context) => {
    //Prepare json data to send notification msg to Slack
    console.log("Send msg to Slack with topic dmhc_sns_topic...");
    var params = {
        Message:  '{ \
                     "version": "0",\
                     "id":"'.concat(context.awsRequestId).concat('",').concat(' \
                     "detail-type":"Is time to check your health! Please go to DMHC Host Probe.", \
                     "source":"aws.events", \
                     "account": "537233203723", \
                     "time":"'.concat(new Date().toISOString()).concat('",').concat(' \
                     "region": "us-west-2" \
                  }')), 
        Subject: "DMHC HOST Probe",
        TopicArn: "arn:aws:sns:us-west-2:537233203723:dmhc_sns_topic"
    };
    // Publish to SNS dmhc_sns_topic
    sns.publish(params, context.done);
    

    // Create publish parameters for SMS Number
    console.log("Send msg to SMS topic...");
    var params = {
      Message: 'Is time to check your health! Please go to DMHC Host Probe.', 
      //Set here your mobile phone number
      PhoneNumber: 'YOUR PHONE NUMBER'
    };
    // Publish to SNS SMS number attach
    sns.publish(params, context.done);

    // Publish to IoT Core topic dmhc/reset
    console.log("Publish in topic dmhc/reset...");
    var params = {
        topic: "dmhc/reset", //send any msg to this topic to reset edukit
        payload: JSON.stringify(event),           
        qos: 0
    };

    //Send reset request to DMHC HOST Probe topic dmhc/reset
    const request = iotdata.publish(params);
    request
        .on('success', () => console.log("Success"))
        .on('error', () => console.log("Error"))
    return new Promise(() => request.send());
};

亞馬遜事件橋

• 創(chuàng)建規(guī)則：dmhc_trigger_reset
• 定義模式：固定速率每 30 分鐘
• 目標(biāo)：Lambda 函數(shù)
• 功能：dmhc_ResetDevice

?

?

?

?

1 / 2 ? dmhc_trigger_reset 已創(chuàng)建

?

在此之前，Lambda 函數(shù)向Amazon SNS服務(wù) topic發(fā)送兩條消息dmhc_sns_topic。

亞馬遜社交網(wǎng)絡(luò)

創(chuàng)建主題：d??mhc_sns_topic

類型標(biāo)準(zhǔn)

SNS 主題 dmhc_sns_topic 已創(chuàng)建

?

一個(gè)由訂閱者處理的正確 json 格式，AWS Chatbot訂閱者將向注冊(cè)的 Slack 頻道發(fā)送通知dmhc-events。

AWS 聊天機(jī)器人

• 配置新客戶端
• 選擇 Slack，配置
• 登錄您的工作區(qū)
• 允許 AWS Chatbot 請(qǐng)求訪問您的 Slack 工作區(qū)的權(quán)限
• 選擇 slack 頻道以發(fā)布通知（dmhc-events在您的 slack 工作區(qū)中創(chuàng)建）
• 配置新頻道：dmhc_chatbot_slack
• 在 us-west-2 中訂閱 SNS 主題dmhc_sns_topic

?

?

?

?

1 / 6 ?配置新客戶端

?

?

?

?

?

1 / 3 ?手機(jī)中的 Slack dmhc-events 頻道

?

另一種是json格式，適合注冊(cè)電話號(hào)碼類型的用戶向手機(jī)發(fā)送短信通知。

亞馬遜 PinPoint

我們需要先注冊(cè)一個(gè)號(hào)碼，然后再向其發(fā)送 SMS 并使用 Amazon Pinpoint 預(yù)置一個(gè)免費(fèi)電話號(hào)碼。

當(dāng)該號(hào)碼已注冊(cè)并具有原始號(hào)碼時(shí)，在沙盒環(huán)境中只有少量測(cè)試和 1 美元的金額，要增加此金額需要?jiǎng)?chuàng)建支持案例和升級(jí)到生產(chǎn)的請(qǐng)求。

• 創(chuàng)建一個(gè)項(xiàng)目：dmhc_pinpoint_project
• 設(shè)置 SMS 和 VoiceSetup SMS 設(shè)置
• 驗(yàn)證沙箱中接收短信的目標(biāo)號(hào)碼（您的電話號(hào)碼將 被 lambda 函數(shù)使用dmhc_ResetDevice）
• 請(qǐng)求發(fā)起免費(fèi)電話號(hào)碼

?

?

?

?

1 / 6 ?創(chuàng)建 dmhc_pinpoint_project 精確定位項(xiàng)目

?

亞馬遜社交網(wǎng)絡(luò)

必須為 SNS 主題創(chuàng)建一個(gè)訂閱 SMS 號(hào)碼dmhc_sns_topic并在 json 消息中設(shè)置subscription filter policy是否存在屬性PhoneNumber，因?yàn)?slack 和 SMS 消息發(fā)送到同一個(gè)主題，并且此策略避免您收到兩條 SMS 消息。

此電話號(hào)碼已在 AWS PinPoint中注冊(cè)，并將由 lambda 函數(shù)使用dmhc_ResetDevice。

?

?

?

?

1 / 3 ?訂閱號(hào)碼到 SNS 主題

?

手機(jī)收到短信

?

概括

此項(xiàng)目中使用的 Amazon Web Services (Oregon us-west-2)

• 物聯(lián)網(wǎng)核心
• 物聯(lián)網(wǎng)分析
• 拉姆達(dá)
• S3
• 應(yīng)用流
• 秘密經(jīng)理
• 時(shí)間流
• 我是
• 波莉
• SDK
• 事件橋
• 社交網(wǎng)絡(luò)
• 聊天機(jī)器人
• 查明

前端選項(xiàng)

• 亞馬遜 QuickSight
• 使用 Amazon Honeycode 開發(fā)應(yīng)用程序
• Grafana 儀表板
• 松弛
• 手機(jī)短信

硬件物聯(lián)網(wǎng)事物

DMHC HOST Probe = AWS IoT Edukit + Heart 單元 + NCIR 單元 + ENVIII 單元