將資料串流匯出至AWS 雲端(console)

下載AWS IoT Greengrass核心 SDKv1.5.0 或更新版本。

解壓縮下載的封裝，以取得軟體開發套件。SDK 為 greengrasssdk 資料夾。

安裝套件相依性，以包含 Lambda 函數部署套件中的軟體開發套件。

將以下 Python 程式碼函數儲存在名為 transfer_stream.py 的本機檔案中。

import asyncio
import logging
import random
import time

from greengrasssdk.stream_manager import (
    ExportDefinition,
    KinesisConfig,
    MessageStreamDefinition,
    ReadMessagesOptions,
    ResourceNotFoundException,
    StrategyOnFull,
    StreamManagerClient,
)


# This example creates a local stream named "SomeStream".
# It starts writing data into that stream and then stream manager automatically exports  
# the data to a customer-created Kinesis data stream named "MyKinesisStream". 
# This example runs forever until the program is stopped.

# The size of the local stream on disk will not exceed the default (which is 256 MB).
# Any data appended after the stream reaches the size limit continues to be appended, and
# stream manager deletes the oldest data until the total stream size is back under 256 MB.
# The Kinesis data stream in the cloud has no such bound, so all the data from this script is
# uploaded to Kinesis and you will be charged for that usage.


def main(logger):
    try:
        stream_name = "SomeStream"
        kinesis_stream_name = "MyKinesisStream"

        # Create a client for the StreamManager
        client = StreamManagerClient()

        # Try deleting the stream (if it exists) so that we have a fresh start
        try:
            client.delete_message_stream(stream_name=stream_name)
        except ResourceNotFoundException:
            pass

        exports = ExportDefinition(
            kinesis=[KinesisConfig(identifier="KinesisExport" + stream_name, kinesis_stream_name=kinesis_stream_name)]
        )
        client.create_message_stream(
            MessageStreamDefinition(
                name=stream_name, strategy_on_full=StrategyOnFull.OverwriteOldestData, export_definition=exports
            )
        )

        # Append two messages and print their sequence numbers
        logger.info(
            "Successfully appended message to stream with sequence number %d",
            client.append_message(stream_name, "ABCDEFGHIJKLMNO".encode("utf-8")),
        )
        logger.info(
            "Successfully appended message to stream with sequence number %d",
            client.append_message(stream_name, "PQRSTUVWXYZ".encode("utf-8")),
        )

        # Try reading the two messages we just appended and print them out
        logger.info(
            "Successfully read 2 messages: %s",
            client.read_messages(stream_name, ReadMessagesOptions(min_message_count=2, read_timeout_millis=1000)),
        )

        logger.info("Now going to start writing random integers between 0 and 1000 to the stream")
        # Now start putting in random data between 0 and 1000 to emulate device sensor input
        while True:
            logger.debug("Appending new random integer to stream")
            client.append_message(stream_name, random.randint(0, 1000).to_bytes(length=4, signed=True, byteorder="big"))
            time.sleep(1)

    except asyncio.TimeoutError:
        logger.exception("Timed out while executing")
    except Exception:
        logger.exception("Exception while running")


def function_handler(event, context):
    return


logging.basicConfig(level=logging.INFO)
# Start up this sample code
main(logger=logging.getLogger())

將下列項目壓縮成名為 transfer_stream_python.zip 的檔案。這是您的 Lambda 函數部署套件。

當您建立 zip 檔案時，請只包含這些項目，而非包含的資料夾。

首先，建立 Lambda 函數。

1. 於 AWS Management Console，請選擇服務，開啟 AWS Lambda 主控台。

2. 選擇CREATE FUNCTION然後選擇Author from scratch (從頭開始撰寫)。

3. 在 Basic information (基本資訊) 區段中，使用下列值：

   • 針對 Function name (函數名稱)，請輸入 TransferStream。

   • 針對 Runtime (執行時間)，選擇 Python 3.7。

   • 適用於許可，請保留預設設定。這會建立授與基本 Lambda 權限的執行角色。此角色不為所用AWS IoT Greengrass。

4. 請在頁面最下方選擇CREATE FUNCTION。

接下來，註冊處理常式並上傳您的 Lambda 函數部署套件。

1. 在「」程式碼索引標籤下代碼來源，選擇上傳來源。從下拉式選單中選擇.zip 檔案。

   

2. 選擇上傳，然後選擇您的transfer_stream_python.zip部署套件。然後選擇 Save (儲存)。

3. 在「」程式碼功能的標籤，在執行時間設定，選擇Edit (編輯)，然後輸入下列值。

   • 針對 Runtime (執行時間)，選擇 Python 3.7。

   • 對於 Handler (處理常式)，輸入 transfer_stream.function_handler。

4. 選擇 Save (儲存)。

   注意

   所以此測試按鈕AWS Lambda主控台不使用此函數。所以此AWS IoT Greengrass核心 SDK 不包含在中獨立執行您的 Greengrass Lambda 函數所需的模組AWS Lambda主控台。這些模塊（例如，greengrass_common) 會在函式部署到 Greengrass 核心後提供給函式。

現在，發佈您的 Lambda 函數的第一個版本並建立版本的別名。

1. 請從操作功能表中選擇發行新版本。

2. 針對 Version description (版本描述)，輸入 First version，然後選擇 Publish (發佈)。

3. 在「」TransferStream：1組態頁面，從動作功能表中，選擇建立別名。

4. 在建立警示頁面上使用下列值：

   • 對於 Name (名稱)，輸入 GG_TransferStream。

   • 對於 Version (版本)，選擇 1。

   注意

   AWS IoT Greengrass不支援 Lambda 函數$LATE版本。

5. 選擇 Create (建立)。

在 中AWS IoT主控台導覽窗格, 下Manage (管理)，展開Greengrass 裝置，然後選擇群組 (V1)。

選擇目標群組。

在群組組態頁面上，選擇Lambda 函數索引標籤。

UNDING我 Lambda 函數，選擇Add。

在「」新增 Lambda 函數頁面中，選擇Lambda 函數為您的 Lambda 函數。

對於Lambda 版本，選擇別名:GG _TransferStream。

現在，設定決定 Greengrass 群組中 Lambda 函數行為的屬性。

在 中Lambda 函數組態區段中，進行下列變更：

選擇新增 Lambda 函數。

在群組組態頁面上，選擇Lambda 函數索引標籤。

UNDING系統 Lambda 函數，SELECT串流管理員，然後檢查狀態。如果是已停用，請選擇 Edit (編輯)。然後，選擇 Enable (啟用) 並 Save (儲存)。您可以使用此教學課程的預設參數設定。如需詳細資訊，請參閱 設定 AWS IoT Greengrass 串流管理員。

在 Local logs configuration (本機日誌組態) 下，檢查是否已設定本機記錄。

如果未對 Greengrass 系統元件或使用者定義的 Lambda 函數設定日誌，請選擇Edit (編輯)。

選擇使用者 Lambda 函數記錄層級和Greengrass 系統日誌層級。

保留記錄層級和磁碟空間限制的預設值，然後選擇 Save (儲存)。

請確定AWS IoT Greengrass核心正在執行。如果需要，請在您的 Raspberry Pi 終端機執行以下命令。

1. 檢查精靈是否有在運作：

   ps aux | grep -E 'greengrass.*daemon'

   若輸出的 root 含有 /greengrass/ggc/packages/ggc-version/bin/daemon 項目，則精靈有在運作。

   注意

   路徑的版本取決於安裝在您的核心裝置中的 AWS IoT Greengrass 核心軟體版本。

2. 啟動協助程式：

   cd /greengrass/ggc/core/
   sudo ./greengrassd start

在群組組態頁面上，選擇部署。

1. 在 中Lambda 函數標籤的系統 Lambda 函數區段中，選取IP 偵測器並選擇Edit (編輯)。

2. 在 中編輯 IP 偵測器設定對話方塊中，選取自動偵測並覆寫 MQTT 代理程式端點。

3. 選擇 Save (儲存)。

   這可讓裝置自動取得核心的連接資訊，例如 IP 位址、DNS、連接埠編號。建議使用自動偵測，但是 AWS IoT Greengrass 也支援手動指定端點。只會在第一次部署群組時收到復原方法的提示。

   注意

   如果出現提示，請授予建立Greengrass 服務角色並將其與您的關聯AWS 帳戶在目前AWS 區域。此角色允許AWS IoT Greengrass存取您的資源AWS服務。

   此部署頁面會顯示部署時間戳記、版本 ID 和狀態。部署完成時，針對部署顯示的狀態應為已完成。

   如需故障診斷協助，請參閱AWS IoT Greengrass 疑難排解。

在 Amazon Kinesis 主控台下Kinesis Data Streams，選擇MyKinesisStream。

在「」MyKinesisStream頁面，選擇監控。如果測試成功，您應該會看到 Put Records (Put 記錄) 圖表中的資料。視您的連線而定，可能需要一分鐘才會顯示資料。

cd /greengrass/ggc/core/
sudo ./greengrassd stop

移除TransferStreamLambda 函數從核心。

1. 在 中AWS IoT主控台導覽窗格, 下Manage (管理)，展開Greengrass 裝置，然後選擇群組 (V1)。

2. UNDINGGreengrass 群組，選擇群組。

3. 在「」Lambda頁面上，選擇省略號 (...) 為TransferStream函數，然後選擇移除功能。

4. 從 Actions (動作) 中，選擇 Deploy (部署)。