Mengambil data ke AWS IoT SiteWise From AWS IoT barang

Navigasikan ke konsol AWS IoT SiteWise tersebut.

Di panel navigasi kiri, pilih Model.

Pilih Buat model aset.

Di bawah Detail model, masukkan nama untuk model Anda. Misalnya, SiteWise Tutorial Device Model.

Di bawah Definisi pengukuran, lakukan hal berikut:

1. Di Nama, masukkan CPU Usage.

2. Di Unit, masukkan%.

3. Biarkan tipe Data sebagai Double.

Properti pengukuran mewakili aliran data mentah perangkat. Untuk informasi selengkapnya, lihat Tentukan aliran data dari peralatan (pengukuran).

Pilih Tambahkan pengukuran baru untuk menambahkan properti pengukuran kedua.

Di baris kedua di bawah Definisi pengukuran, lakukan hal berikut:

1. Di Nama, masukkan Memory Usage.

2. Di Unit, masukkan%.

3. Biarkan tipe Data sebagai Double.

Di bawah Definisi metrik, lakukan hal berikut:

1. Di Nama, masukkan Average CPU Usage.

2. Di Formula, masukkanavg(CPU Usage). Pilih CPU Usage dari daftar pelengkapan otomatis saat muncul.

3. Di Interval waktu, masukkan5 minutes.

Properti metrik menentukan perhitungan agregasi yang memproses semua titik data input selama interval dan menghasilkan satu titik data per interval. Properti metrik ini menghitung penggunaan CPU rata-rata setiap perangkat setiap 5 menit. Untuk informasi selengkapnya, lihat Data agregat dari properti dan aset lainnya (metrik).

Pilih Tambahkan metrik baru untuk menambahkan properti metrik kedua.

Di baris kedua di bawah Definisi metrik, lakukan hal berikut:

1. Di Nama, masukkan Average Memory Usage.

2. Di Formula, masukkanavg(Memory Usage). Pilih Memory Usage dari daftar pelengkapan otomatis saat muncul.

3. Di Interval waktu, masukkan5 minutes.

Properti metrik ini menghitung penggunaan memori rata-rata setiap perangkat setiap 5 menit.

(Opsional) Tambahkan metrik tambahan lain yang ingin Anda hitung per perangkat. Beberapa fungsi menarik termasuk min danmax. Untuk informasi selengkapnya, lihat Gunakan ekspresi rumus. Pada Langkah 4: Membuat model aset armada perangkat, Anda membuat aset induk yang dapat menghitung metrik menggunakan data dari seluruh armada perangkat Anda.

Pilih Buat model.

Navigasikan ke konsol AWS IoT SiteWise tersebut.

Di panel navigasi kiri, pilih Model.

Pilih Buat model aset.

Di bawah Detail model, masukkan nama untuk model Anda. Misalnya, SiteWise Tutorial Device Fleet Model.

Di bawah Definisi hierarki, lakukan hal berikut:

1. Di Nama hierarki, masukkanDevice.

2. Di Model hierarki, pilih model aset perangkat Anda (SiteWise Tutorial Device Model).

Hirarki mendefinisikan hubungan antara model aset induk (armada) dan model aset anak (perangkat). Aset induk dapat mengakses data properti aset anak. Saat membuat aset nanti, Anda perlu mengaitkan aset anak ke aset induk sesuai dengan definisi hierarki dalam model aset induk. Untuk informasi selengkapnya, lihat Hierarki aset mewakili hubungan peralatan.

Di bawah Definisi metrik, lakukan hal berikut:

1. Di Nama, masukkan Average CPU Usage.

2. Di Formula, masukkanavg(Device | Average CPU Usage). Saat daftar pelengkapan otomatis muncul, pilih Device untuk memilih hierarki, lalu pilih Average CPU Usage untuk memilih metrik dari aset perangkat yang Anda buat sebelumnya.

3. Di Interval waktu, masukkan5 minutes.

Properti metrik ini menghitung rata-rata penggunaan CPU dari semua aset perangkat yang terkait dengan aset armada melalui Device hierarki.

Pilih Tambahkan metrik baru untuk menambahkan properti metrik kedua.

Di baris kedua di bawah Definisi metrik, lakukan hal berikut:

1. Di Nama, masukkan Average Memory Usage.

2. Di Formula, masukkanavg(Device | Average Memory Usage). Saat daftar pelengkapan otomatis muncul, pilih Device untuk memilih hierarki, lalu pilih Average Memory Usage untuk memilih metrik dari aset perangkat yang Anda buat sebelumnya.

3. Di Interval waktu, masukkan5 minutes.

Properti metrik ini menghitung penggunaan memori rata-rata semua aset perangkat yang terkait dengan aset armada melalui Device hierarki.

(Opsional) Tambahkan metrik tambahan lain yang ingin Anda hitung di seluruh armada perangkat Anda.

Pilih Buat model.

Navigasikan ke konsol AWS IoT SiteWise tersebut.

Di panel navigasi kiri, pilih A set.

Pilih Buat aset.

Di bawah Informasi model, pilih model aset perangkat Anda,SiteWise Tutorial Device Model.

Di bawah Informasi aset, masukkan nama untuk aset Anda. Misalnya, SiteWise Tutorial Device 1.

Pilih Buat aset.

Untuk aset perangkat baru Anda, pilih Edit.

Di bawah Pengukuran:

1. Di bawah CPU Usage, masukkan /tutorial/device/SiteWiseTutorialDevice1/cpu sebagai alias properti. Anda menyer AWS IoT takan nama benda di alias properti, sehingga Anda dapat menyerap data dari semua perangkat Anda menggunakan satu AWS IoT aturan.

2. Di bawah Memory Usage, masukkan /tutorial/device/SiteWiseTutorialDevice1/memory sebagai alias properti.

Pilih Simpan.

Navigasikan ke konsol AWS IoT SiteWise tersebut.

Di panel navigasi kiri, pilih A set.

Pilih Buat aset.

Di bawah Informasi model, pilih model aset armada perangkat Anda,SiteWise Tutorial Device Fleet Model.

Di bawah Informasi aset, masukkan nama untuk aset Anda. Misalnya, SiteWise Tutorial Device Fleet 1.

Pilih Buat aset.

Untuk aset armada perangkat baru Anda, pilih Edit.

Di bawah Aset yang terkait dengan aset ini, pilih Tambahkan aset terkait dan lakukan hal berikut:

1. Di bawah Hierarki, pilih Device. Hirarki ini mengidentifikasi hubungan hierarkis antara aset armada perangkat dan perangkat. Anda mendefinisikan hierarki ini dalam model aset armada perangkat sebelumnya dalam tutorial ini.

2. Di bawah Aset, pilih aset perangkat Anda, SiteWise Tutorial Device 1.

(Opsional) Jika Anda membuat beberapa aset perangkat sebelumnya, ulangi langkah 8 hingga 10 untuk setiap aset perangkat yang Anda buat.

Pilih Simpan.

Anda sekarang harus melihat aset perangkat Anda diatur sebagai hierarki.

Navigasikan ke konsol AWS IoT tersebut.

Di panel navigasi kiri, pilih Perutean pesan dan kemudian pilih A turan.

Pilih Buat aturan.

Masukkan nama dan deskripsi untuk aturan Anda dan pilih Ber ikutnya.

Masukkan pernyataan SQL berikut dan pilih Ber ikutnya.

SELECT
  *
FROM
  '$aws/things/+/shadow/update/accepted'
WHERE
  startsWith(topic(3), "SiteWiseTutorialDevice")

Pernyataan kueri aturan ini berfungsi karena layanan bayangan perangkat menerbitkan pembaruan bayangan ke$aws/things/thingName/shadow/update/accepted. Untuk informasi selengkapnya tentang bayangan perangkat, lihat Layanan bayangan perangkat di Panduan AWS IoT Pengembang.

Dalam WHERE klausa, pernyataan kueri aturan ini menggunakan topic(3) fungsi untuk mendapatkan nama benda dari segmen ketiga topik. Kemudian, pernyataan menyaring perangkat yang memiliki nama yang tidak cocok dengan perangkat tutorial. Untuk informasi selengkapnya tentang AWS IoT SQL, lihat referensi AWS IoT SQL di Panduan AWS IoT Pengembang.

Di bawah Tind akan aturan, pilih Kirim data pesan ke properti aset di AWS IoT SiteWise dan lakukan hal berikut:

1. Pilih Berdasarkan alias properti.

2. Di alias properti, masukkan/tutorial/device/${topic(3)}/cpu.

   ${...}Sintaks adalah template substitusi. AWS IoT mengevaluasi isi dalam kawat gigi. Template substitusi ini menarik nama benda dari topik untuk membuat alias unik untuk setiap hal. Untuk informasi selengkapnya, lihat Template substitusi di Panduan AWS IoT Pengembang.

   catatan

   Karena ekspresi dalam template substitusi dievaluasi secara terpisah dari SELECT pernyataan, Anda tidak dapat menggunakan template substitusi untuk mereferensikan alias yang dibuat menggunakan AS klausa. Anda hanya dapat merujuk informasi yang ada di muatan asli, selain fungsi dan operator yang didukung.

3. Di ID Entri - opsional , masukkan${concat(topic(3), "-cpu-", floor(state.reported.timestamp))}.

   ID entri secara unik mengidentifikasi setiap upaya entri nilai. Jika entri mengembalikan kesalahan, Anda dapat menemukan ID entri di keluaran kesalahan untuk memecahkan masalah. Template substitusi dalam ID entri ini menggabungkan nama benda dan stempel waktu perangkat yang dilaporkan. Misalnya, ID entri yang dihasilkan mungkin terlihat sepertiSiteWiseTutorialDevice1-cpu-1579808494.

4. Dalam Waktu dalam detik, masukkan${floor(state.reported.timestamp)}.

   Template substitusi ini menghitung waktu dalam detik dari cap waktu perangkat yang dilaporkan. Dalam tutorial ini, perangkat melaporkan stempel waktu dalam hitungan detik dalam waktu zaman Unix sebagai angka float point.

5. Di Offset di nano - opsional , masukkan${floor((state.reported.timestamp % 1) * 1E9)}.

   Template substitusi ini menghitung offset nanodetik dari waktu dalam detik dengan mengubah bagian desimal dari cap waktu yang dilaporkan perangkat.

   catatan

   AWS IoT SiteWise mengharuskan data Anda memiliki stempel waktu saat ini dalam waktu zaman Unix. Jika perangkat Anda tidak melaporkan waktu secara akurat, Anda bisa mendapatkan waktu saat ini dari mesin AWS IoT aturan dengan timestamp (). Fungsi ini melaporkan waktu dalam milidetik, jadi Anda harus memperbarui parameter waktu tindakan aturan Anda ke nilai berikut:

   • Dalam Waktu dalam detik, masukkan${floor(timestamp() / 1E3)}.

   • Di Offset in nano, masukkan${(timestamp() % 1E3) * 1E6}.

6. Di Jenis data, pilih Double.

   Tipe data ini harus sesuai dengan tipe data properti aset yang Anda tentukan dalam model aset.

7. Dalam Value (Nilai), masukkan ${state.reported.cpu}. Dalam template substitusi, Anda menggunakan . operator untuk mengambil nilai dari dalam struktur JSON.

8. Pilih Tambah entri untuk menambahkan entri baru untuk properti penggunaan memori, dan selesaikan langkah-langkah berikut lagi untuk properti itu:

   1. Pilih Berdasarkan alias properti.

   2. Di alias properti, masukkan/tutorial/device/${topic(3)}/memory.

   3. Di ID Entri - opsional , masukkan${concat(topic(3), "-memory-", floor(state.reported.timestamp))}.

   4. Dalam Waktu dalam detik, masukkan${floor(state.reported.timestamp)}.

   5. Di Offset di nano - opsional , masukkan${floor((state.reported.timestamp % 1) * 1E9)}.

   6. Di Jenis data, pilih Double.

   7. Dalam Value (Nilai), masukkan ${state.reported.memory}.

9. Di bawah Peran IAM, pilih Buat peran baru untuk membuat peran IAM untuk tindakan aturan ini. Peran ini memungkinkan AWS IoT untuk mendorong data ke properti di aset armada perangkat Anda dan hierarki asetnya.

10. Masukkan nama peran dan pilih Buat.

(Opsional) Konfigurasikan tindakan kesalahan yang dapat Anda gunakan untuk memecahkan masalah aturan Anda. Untuk informasi selengkapnya, lihat Memecahkan masalah aturan (AWS IoT SiteWise).

Pilih Berikutnya.

Tinjau pengaturan dan pilih Buat untuk membuat aturan.

Navigasikan ke konsol AWS IoT tersebut.

Di bagian bawah panel navigasi kiri, pilih Peng aturan.

Simpan titik akhir kustom Anda untuk digunakan dengan skrip klien perangkat. Anda menggunakan titik akhir ini untuk berinteraksi dengan bayangan benda Anda. Titik akhir ini unik untuk akun Anda di Wilayah saat ini.

Titik akhir kustom Anda akan terlihat seperti contoh berikut.

identifier.iot.region.amazonaws.com

Buka baris perintah dan jalankan perintah berikut untuk menavigasi ke direktori tutorial yang Anda buat sebelumnya.

cd iot-sitewise-rule-tutorial

Jalankan perintah berikut untuk menginstal AWS IoT Device SDK for Python.

pip3 install AWSIoTPythonSDK

Untuk informasi selengkapnya, lihat AWS IoT Device SDK for Python di Panduan AWS IoT Pengembang

Jalankan perintah berikut untuk menginstal psutil, proses lintas platform dan pustaka utilitas sistem.

pip3 install psutil

Untuk informasi lebih lanjut, lihat psutil di Indeks Paket Python.

Buat file yang di thing_performance.py panggil di iot-sitewise-rule-tutorial direktori dan kemudian salin kode Python berikut ke dalam file.

import AWSIoTPythonSDK.MQTTLib as AWSIoTPyMQTT

import json
import psutil
import argparse
import logging
import time


# Configures the argument parser for this program.
def configureParser():
    parser = argparse.ArgumentParser()
    parser.add_argument(
        "-e",
        "--endpoint",
        action="store",
        required=True,
        dest="host",
        help="Your AWS IoT custom endpoint",
    )
    parser.add_argument(
        "-r",
        "--rootCA",
        action="store",
        required=True,
        dest="rootCAPath",
        help="Root CA file path",
    )
    parser.add_argument(
        "-c",
        "--cert",
        action="store",
        required=True,
        dest="certificatePath",
        help="Certificate file path",
    )
    parser.add_argument(
        "-k",
        "--key",
        action="store",
        required=True,
        dest="privateKeyPath",
        help="Private key file path",
    )
    parser.add_argument(
        "-p",
        "--port",
        action="store",
        dest="port",
        type=int,
        default=8883,
        help="Port number override",
    )
    parser.add_argument(
        "-n",
        "--thingName",
        action="store",
        required=True,
        dest="thingName",
        help="Targeted thing name",
    )
    parser.add_argument(
        "-d",
        "--requestDelay",
        action="store",
        dest="requestDelay",
        type=float,
        default=1,
        help="Time between requests (in seconds)",
    )
    parser.add_argument(
        "-v",
        "--enableLogging",
        action="store_true",
        dest="enableLogging",
        help="Enable logging for the AWS IoT Device SDK for Python",
    )
    return parser


# An MQTT shadow client that uploads device performance data to AWS IoT at a regular interval.
class PerformanceShadowClient:
    def __init__(
        self,
        thingName,
        host,
        port,
        rootCAPath,
        privateKeyPath,
        certificatePath,
        requestDelay,
    ):
        self.thingName = thingName
        self.host = host
        self.port = port
        self.rootCAPath = rootCAPath
        self.privateKeyPath = privateKeyPath
        self.certificatePath = certificatePath
        self.requestDelay = requestDelay

    # Updates this thing's shadow with system performance data at a regular interval.
    def run(self):
        print("Connecting MQTT client for {}...".format(self.thingName))
        mqttClient = self.configureMQTTClient()
        mqttClient.connect()
        print("MQTT client for {} connected".format(self.thingName))
        deviceShadowHandler = mqttClient.createShadowHandlerWithName(
            self.thingName, True
        )

        print("Running performance shadow client for {}...\n".format(self.thingName))
        while True:
            performance = self.readPerformance()
            print("[{}]".format(self.thingName))
            print("CPU:\t{}%".format(performance["cpu"]))
            print("Memory:\t{}%\n".format(performance["memory"]))
            payload = {"state": {"reported": performance}}
            deviceShadowHandler.shadowUpdate(
                json.dumps(payload), self.shadowUpdateCallback, 5
            )
            time.sleep(args.requestDelay)

    # Configures the MQTT shadow client for this thing.
    def configureMQTTClient(self):
        mqttClient = AWSIoTPyMQTT.AWSIoTMQTTShadowClient(self.thingName)
        mqttClient.configureEndpoint(self.host, self.port)
        mqttClient.configureCredentials(
            self.rootCAPath, self.privateKeyPath, self.certificatePath
        )
        mqttClient.configureAutoReconnectBackoffTime(1, 32, 20)
        mqttClient.configureConnectDisconnectTimeout(10)
        mqttClient.configureMQTTOperationTimeout(5)
        return mqttClient

    # Returns the local device's CPU usage, memory usage, and timestamp.
    def readPerformance(self):
        cpu = psutil.cpu_percent()
        memory = psutil.virtual_memory().percent
        timestamp = time.time()
        return {"cpu": cpu, "memory": memory, "timestamp": timestamp}

    # Prints the result of a shadow update call.
    def shadowUpdateCallback(self, payload, responseStatus, token):
        print("[{}]".format(self.thingName))
        print("Update request {} {}\n".format(token, responseStatus))


# Configures debug logging for the AWS IoT Device SDK for Python.
def configureLogging():
    logger = logging.getLogger("AWSIoTPythonSDK.core")
    logger.setLevel(logging.DEBUG)
    streamHandler = logging.StreamHandler()
    formatter = logging.Formatter(
        "%(asctime)s - %(name)s - %(levelname)s - %(message)s"
    )
    streamHandler.setFormatter(formatter)
    logger.addHandler(streamHandler)


# Runs the performance shadow client with user arguments.
if __name__ == "__main__":
    parser = configureParser()
    args = parser.parse_args()
    if args.enableLogging:
        configureLogging()
    thingClient = PerformanceShadowClient(
        args.thingName,
        args.host,
        args.port,
        args.rootCAPath,
        args.privateKeyPath,
        args.certificatePath,
        args.requestDelay,
    )
    thingClient.run()

J thing_performance.py alankan dari baris perintah dengan parameter berikut:

Perintah Anda akan terlihat mirip dengan contoh berikut.

python3 thing_performance.py \
  --thingName SiteWiseTutorialDevice1 \
  --endpoint identifier.iot.region.amazonaws.com \
  --rootCA AmazonRootCA1.pem \
  --cert device1/thing-id-certificate.pem.crt \
  --key device1/thing-id-private.pem.key

Jika Anda menjalankan skrip untuk AWS IoT hal-hal tambahan, perbarui nama benda dan direktori sertifikat yang sesuai.

Coba buka dan tutup program di perangkat Anda untuk melihat bagaimana penggunaan CPU dan memori berubah. Skrip mencetak setiap pembacaan penggunaan CPU dan memori. Jika skrip berhasil mengunggah data ke layanan bayangan perangkat, output skrip akan terlihat seperti contoh berikut.

[SiteWiseTutorialDevice1]
CPU:    24.6%
Memory: 85.2%

[SiteWiseTutorialDevice1]
Update request e6686e44-fca0-44db-aa48-3ca81726f3e3 accepted

Ikuti langkah-langkah ini untuk memverifikasi bahwa skrip memperbarui bayangan perangkat:

1. Navigasikan ke konsol AWS IoT tersebut.

2. Di panel navigasi kiri, pilih Semua perangkat dan kemudian pilih Th ings.

3. Pilih barang Anda, SiteWiseTutorialDevice.

4. Pilih tab Device Shadows, pilih Classic Shadow, dan verifikasi bahwa status Shadow terlihat seperti contoh berikut.

   {
     "reported": {
       "cpu": 24.6,
       "memory": 85.2,
       "timestamp": 1579567542.2835066
     }
   }

   Jika status bayangan benda Anda kosong atau tidak terlihat seperti contoh sebelumnya, periksa apakah skrip sedang berjalan dan berhasil terhubung AWS IoT. Jika skrip terus habis saat menghubungkan ke AWS IoT, periksa apakah kebijakan item Anda dikonfigurasi sesuai dengan tutorial ini.

Ikuti langkah-langkah berikut untuk memverifikasi bahwa tindakan aturan mengirim data ke AWS IoT SiteWise:

1. Navigasikan ke konsol AWS IoT SiteWise tersebut.

2. Di panel navigasi kiri, pilih A set.

3. Pilih panah di sebelah aset armada perangkat Anda (SiteWise Tutorial Device Fleet 1) untuk memperluas hierarki asetnya, lalu pilih aset perangkat Anda (SiteWise Tutorial Device1).

4. Pilih Pengukuran.

5. Verifikasi bahwa sel nilai terbaru memiliki nilai untuk CPU Usage Memory Usage properti dan.

   

6. Jika Memory Usage properti CPU Usage dan tidak memiliki nilai terbaru, segarkan halaman. Jika nilai tidak muncul setelah beberapa menit, lihatMemecahkan masalah aturan (AWS IoT SiteWise).

Arahkan ke AWS IoT SiteWise konsol

Di panel navigasi kiri, pilih A set.

Saat Anda menghapus aset di AWS IoT SiteWise, Anda harus terlebih dahulu memisahkannya.

Selesaikan langkah-langkah berikut untuk memisahkan aset perangkat Anda dari aset armada perangkat Anda:

1. Pilih aset armada perangkat Anda (SiteWise Tutorial Device Fleet 1).

2. Pilih Edit.

3. Di bawah Aset yang terkait dengan aset ini, pilih Put uskan kait annya untuk setiap aset perangkat yang terkait dengan aset armada perangkat ini.

4. Pilih Simpan.

   Anda sekarang akan melihat aset perangkat Anda tidak lagi diatur sebagai hierarki.

Pilih aset perangkat Anda (SiteWise Tutorial Device1).

Pilih Hapus.

Dalam dialog konfirmasi, masukkan Delete dan kemudian pilih H apus.

Ulangi langkah 4 hingga 6 untuk setiap aset perangkat dan aset armada perangkat (SiteWise Tutorial Device Fleet 1).

Navigasikan ke konsol AWS IoT SiteWise tersebut.

Jika belum melakukannya, hapus aset armada perangkat dan perangkat Anda. Untuk informasi lebih lanjut, lihat prosedur sebelumnya. Anda tidak dapat menghapus model jika Anda memiliki aset yang dibuat dari model tersebut.

Di panel navigasi kiri, pilih Model.

Pilih model aset armada perangkat Anda (SiteWise Tutorial Device Fleet Model).

Saat menghapus model aset hierarkis, mulailah dengan menghapus model aset induk terlebih dahulu.

Pilih Hapus.

Dalam dialog konfirmasi, masukkan Delete dan kemudian pilih H apus.

Ulangi langkah 4 hingga 6 untuk model aset perangkat Anda (SiteWise Tutorial Device Model).

Navigasikan ke konsol AWS IoT tersebut.

Di panel navigasi kiri, pilih Perutean pesan dan kemudian pilih A turan.

Pilih aturan Anda dan pilih H apus.

Dalam dialog konfirmasi, masukkan nama aturan dan kemudian pilih H apus.