Ekspor aliran data ke AWS Cloud (konsol)

Unduh AWS IoT Greengrass Core SDK for Python v1.5.0 atau yang lebih baru.

Unzip paket unduhan untuk mendapatkan SDK. SDK adalah folder greengrasssdk ini.

Instal paket dependensi untuk menyertakan dengan SDK dalam paket deployment fungsi Lambda Anda.

Simpan fungsi kode Python berikut dalam sebuah file lokal bernama 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())

Zip item berikut ke dalam file bernama transfer_stream_python.zip. Ini adalah paket deployment fungsi Lambda Anda.

Ketika Anda membuat file zip ini, termasuk hanya item ini, bukan folder yang berisi.

Pertama, buat fungsi Lambda.

1. Di AWS Management Console, pilih Layanan, dan buka konsol AWS Lambda tersebut.

2. Pilih Buat fungsi dan kemudian Tulis dari awal.

3. Di bagian Informasi dasar tersebut, gunakan nilai-nilai berikut:

   • Untuk Nama fungsi, masukkan TransferStream.

   • Untuk Waktu pengoperasian, pilih Python 3.7.

   • Untuk Izin, pertahankan pengaturan default. Hal ini menciptakan peran eksekusi yang memberikan izin Lambda basic. Peran ini tidak digunakan oleh AWS IoT Greengrass.

4. Di bagian bawah halaman, pilih Buat Fungsi.

Selanjutnya, daftarkan handler dan unggah paket deployment fungsi Lambda Anda.

1. Pada tab Kode ini, di bawah Sumber kode, pilih Unggah dari. Dari dropdown, pilih file .zip.

   

2. Pilih Unggah, lalu pilih paket deployment transfer_stream_python.zip Anda. Lalu, pilih Simpan.

3. Pada tab Kode fungsi, di bawah Pengaturan waktu aktif, pilih Edit, dan kemudian masukkan nilai-nilai berikut.

   • Untuk Waktu pengoperasian, pilih Python 3.7.

   • Untuk Handler, masukkan transfer_stream.function_handler

4. Pilih Save (Simpan).

   catatan

   Tombol Tes pada konsol AWS Lambda tidak bekerja dengan fungsi ini. Pada AWS IoT Greengrass Core SDK tidak berisi modul yang diperlukan untuk menjalankan fungsi Greengrass Lambda Anda secara independen di konsol AWS Lambda tersebut. Modul-modul ini (misalnya, greengrass_common) dipasok ke fungsi setelah mereka di-deploy ke core Greengrass Anda.

Sekarang, publikasikan versi pertama fungsi Lambda Anda dan membuat alias untuk versi.

1. Dari menu Tindakan ini, pilih Terbitkan versi baru.

2. Untuk Versi Deskripsi, masukkan First version, lalu pilih Publikasikan.

3. PadaTransferStream: 1halaman konfigurasi, dariTindakanmenu, pilihMembuat alias.

4. Pada halaman Buat alias baru ini, gunakan nilai-nilai berikut:

   • Untuk Nama, masukkan GG_TransferStream.

   • Untuk Versi, pilih 1.

   catatan

   AWS IoT Greengrass tidak support alias Lambda untuk versi $TERBARU ini.

5. Pilih Create (Buat).

DiAWS IoTpanel navigasi konsol, di bawahKelola, PerluasPerangkat Greengrass, lalu pilihGrup (V1).

Pilih grup target.

Pada halaman konfigurasi grup, pilihFungsi Lambdatab.

Di bawahFungsi Lambda saya, pilihTambahkan.

PadaTambahkan fungsi Lambdahalaman, pilihFungsi Lambdauntuk fungsi Lambda Anda.

UntukVersi Lambda, pilihAlias: GG_TransferStream.

Sekarang, konfigurasikan properti yang menentukan perilaku fungsi Lambda dalam grup Greengrass.

DiKonfigurasi fungsi Lambdabagian, lakukan perubahan berikut:

PilihTambahkan fungsi Lambda.

Pada halaman konfigurasi grup, pilihFungsi Lambdatab.

Di bawahFungsi Lambda sistem, pilihManajer pengaliran, dan periksa statusnya. Jika dinonaktifkan, pilih Edit. Kemudian, pilih Aktifkan dan Simpan. Anda dapat menggunakan pengaturan parameter default untuk tutorial ini. Untuk informasi selengkapnya, lihat Konfigurasikan manajer pengaliran AWS IoT Greengrass.

Di bawah Konfigurasikan catatan lokal, periksa apakah pengelogan lokal dikonfigurasi.

Jika catatan tidak dikonfigurasi untuk komponen sistem Greengrass atau fungsi Lambda yang ditetapkan pengguna, pilih Edit.

PilihTingkat log fungsi Lambda penggunadanTingkat log sistem Greengrass.

Menjaga nilai default untuk tingkat pencatatan dan batas ruang disk, lalu pilih Simpan.

Pastikan bahwa core AWS IoT Greengrass sedang berjalan. Jalankan perintah berikut di terminal Raspberry Pi Anda, sesuai kebutuhan.

1. Untuk memeriksa apakah daemon sedang berjalan:

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

   Jika outputnya berisi entri root untuk /greengrass/ggc/packages/ggc-version/bin/daemon, maka daemon sedang berjalan.

   catatan

   Versi di jalur tergantung pada versi perangkat lunak AWS IoT Greengrass core yang diinstal pada perangkat core Anda.

2. Untuk memulai daemon:

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

Pada halaman konfigurasi grup, pilihDeploy.

1. DiFungsi Lambdatab, di bawahFungsi Lambda sistembagian, pilihDetektor IPdan pilihlahedit.

2. DiMengedit pengaturan detektor IPkotak dialog, pilihSecara otomatis mendeteksi dan mengganti titik akhir broker MQTT.

3. Pilih Save (Simpan).

   Hal ini mengaktifkan perangkat untuk secara otomatis memperoleh informasi konektivitas untuk core, seperti alamat IP, DNS, dan nomor port. Deteksi otomatis direkomendasikan, namun AWS IoT Greengrass juga support titik akhir yang ditentukan secara manual. Anda hanya diminta untuk metode penemuan pertama kalinya bahwa grup di-deploy.

   catatan

   Jika diminta, berikan izin untuk membuat Peran layanan Greengrass dan kaitkan dengan Akun AWS Anda pada Wilayah AWS. Peran ini memungkinkan AWS IoT Greengrass untuk mengakses sumber daya Anda di layanan AWS ini.

   Halaman Deployment menampilkan timestamp deployment, ID versi, dan status. Setelah selesai, status yang ditampilkan untuk deployment seharusnyaCompleted (Lengkap).

   Untuk bantuan penyelesaian masalah, lihat Pemecahan Masalah AWS IoT Greengrass.

Di konsol Amazon Kinesis, di bawahKinesis data streams, pilihMyKinesisStream.

PadaMyKinesisStreamhalaman, pilihPemantauan. Jika uji berhasil, Anda akan melihat data di bagan Pasang Catatan ini. Tergantung pada koneksi Anda, mungkin diperlukan waktu satu menit sebelum data ditampilkan.

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

HapusTransferStreamFungsi Lambda dari inti.

1. DiAWS IoTpanel navigasi konsol, di bawahKelola, PerluasPerangkat Greengrass, lalu pilihGrup (V1).

2. Di bawah grup Greengrass, pilih grup Anda.

3. PadaLambdahalaman, pilih elips (...) untukTransferStreamfungsi, dan kemudian pilihHapus fungsi.

4. Dari Tindakan, pilih Men-deploy.