Amazon Monitron steht Neukunden nicht mehr zur Verfügung. Bestandskunden können den Service weiterhin wie gewohnt nutzen. Informationen zu Funktionen, die Amazon Monitron ähneln, finden Sie in unserem [Blogbeitrag](https://aws.amazon.com/blogs/machine-learning/maintain-access-and-consider-alternatives-for-amazon-monitron). Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich. # Amazon Monitron Kinesis-Datenexport v2 Sie können eingehende Messdaten und die entsprechenden Inferenzergebnisse aus Amazon Monitron exportieren und Analysen in Echtzeit durchführen. Beim Datenexport werden Live-Daten an Kinesis gestreamt. **Topics** + [Exportieren Ihrer Daten in einen Kinesis-Stream](#exporting-stream-procedure-v2) + [Einstellungen für den Live-Datenexport bearbeiten](#edit-live-export-v2) + [Einen Live-Datenexport beenden](#stop-kinesis-export-v2) + [Fehler beim Datenexport anzeigen](#viewing-kinesis-export-errors-v2) + [Verwendung der serverseitigen Verschlüsselung für den Kinesis-Stream](#data-export-server-side-encryption-v2) + [Überwachung mit Amazon CloudWatch Logs](data-export-cloudwatch-logs-v2.md) + [Speichern exportierter Daten in Amazon S3](kinesis-store-S3-v2.md) + [Daten mit Lambda verarbeiten](data-export-lambda-v2.md) + [Grundlegendes zum v2-Datenexportschema](data-export-schema-v2.md) + [Migration von Kinesis v1 zu v2](migration-from-v1-to-v2.md) ## Exportieren Ihrer Daten in einen Kinesis-Stream 1. Wählen Sie auf der Hauptseite Ihres Projekts unten auf der Seite auf der rechten Seite die Option **Live-Datenexport starten** aus. 1. Führen **Sie unter Kinesis-Datenstrom auswählen** einen der folgenden Schritte aus: + Geben Sie den Namen eines vorhandenen Streams in das Suchfeld ein. Fahren Sie dann mit Schritt 5 fort. + Wählen Sie **Neuen Datenstrom erstellen** aus. 1. Geben Sie auf der Seite **Datenstream erstellen** unter **Datenstream-Konfiguration** den Namen Ihres Datenstroms ein. 1. Wählen Sie unter Datenstromkapazität Ihren Kapazitätsmodus aus: + Wenn die Durchsatzanforderungen Ihres Datenstroms unvorhersehbar und variabel sind, wählen Sie **On-Demand**. + Wenn Sie die Durchsatzanforderungen Ihres Datenstroms zuverlässig abschätzen können, wählen Sie **Bereitgestellt.** **Geben Sie dann unter Bereitgestellte Shards die Anzahl der Shards ein, die Sie erstellen möchten, oder wählen Sie den Shard-Schätzer aus.** 1. Klicken Sie auf **Create data stream (Daten-Stream erstellen)**. ## Einstellungen für den Live-Datenexport bearbeiten So bearbeiten Sie Ihre Einstellungen für den Live-Datenexport: 1. Öffnen Sie die Amazon Monitron Monitron-Konsole. 1. Wählen Sie im Navigationsbereich **Projekte** aus. 1. Wenn Sie mehrere Projekte haben, wählen Sie das Projekt aus, für das Sie die Exporteinstellungen bearbeiten möchten. 1. Wählen Sie auf der Hauptseite Ihres Projekts unter **Live-Datenexport** im Drop-down-Menü **Aktionen** die Option **Einstellungen für den Live-Datenexport bearbeiten** aus. ## Einen Live-Datenexport beenden 1. Öffnen Sie die Amazon Monitron Monitron-Konsole. 1. Wählen Sie im Navigationsbereich **Projekte** aus. 1. Wenn Sie mehrere Projekte haben, wählen Sie das Projekt aus, für das Sie die Exporteinstellungen bearbeiten möchten. 1. Wählen Sie auf der Hauptseite Ihres Projekts unter **Live-Datenexport** im Drop-down-Menü **Aktionen** die Option **Live-Datenexport beenden** aus. 1. Wählen Sie im Popup-Fenster die Option **Stopp**. ## Fehler beim Datenexport anzeigen So zeigen Sie die Fehlermeldungen in der CloudWatch Logs-Oberfläche an: + Wählen Sie auf der Amazon Monitron Monitron-Konsole auf der Hauptseite Ihres Projekts unter **Live-Datenexport** die Option **CloudWatch Protokollgruppe** aus. ## Verwendung der serverseitigen Verschlüsselung für den Kinesis-Stream Sie können die serverseitige Verschlüsselung für Ihren Kinesis-Stream aktivieren, bevor Sie den Kinesis-Datenexport einrichten. Wenn jedoch die serverseitige Verschlüsselung aktiviert ist, nachdem der Kinesis-Datenexport eingerichtet wurde, kann Amazon Monitron nicht im Stream veröffentlichen. Das liegt daran, dass Amazon Monitron nicht berechtigt sein wird, [kms:](https://docs.aws.amazon.com/kms/latest/APIReference/API_GenerateDataKey.html) aufzurufen, GenerateDataKey um an Kinesis gesendete Daten zu verschlüsseln. Um dieses Problem zu umgehen, folgen Sie den Anweisungen unter[Einstellungen für den Live-Datenexport bearbeiten](#edit-live-export-v2), ohne jedoch die Konfiguration zu ändern. Dadurch wird die von Ihnen eingerichtete Verschlüsselung mit Ihrer Exportkonfiguration verknüpft. # Überwachung mit Amazon CloudWatch Logs Sie können den Live-Datenexport von Amazon Monitron mit Amazon CloudWatch Logs überwachen. Wenn eine Messung nicht exportiert werden kann, sendet Amazon Monitron ein Protokollereignis an Ihre CloudWatch Logs. Sie können auch einen Metrikfilter für das Fehlerprotokoll einrichten, um Metriken zu generieren und Alarme einzurichten. Ein Alarm kann nach bestimmten Schwellenwerten Ausschau halten und Benachrichtigungen senden oder Maßnahmen ergreifen, wenn diese Schwellenwerte erreicht sind. Weitere Informationen finden Sie [im CloudWatch Benutzerhandbuch](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/WhatIsCloudWatch.html). Amazon Monitron sendet Protokollereignisse an die Protokollgruppe/aws/monitron/data-export/ \$1HASH\$1ID\$1. Das Protokollereignis hat das folgende JSON-Format: ``` { "assetName": "string", "destination": "string", "errorCode": "string", "errorMessage": "string", "eventId": "string", "eventType": "string", "positionName": "string", "projectName": "string", "projectId": "string", "sensorId": "string", "gatewayId": "string", "siteName": "string", "timestamp": "string" } ``` AssetName + Der in der App angezeigte Asset-Name + Typ: Zeichenfolge Ziel + Der ARN des Kinesis-Datenstroms + Typ: Zeichenfolge + Muster: arn:aws:kinesis: \$1\$1REGION\$1\$1: \$1\$1AWS\$1ACCOUNT\$1ID\$1\$1 :stream/ \$1\$1STREAM\$1NAME\$1\$1 errorCode + Der Fehlercode + Typ: Zeichenfolge + Zulässige Werte: `INTERNAL_SEVER_ERROR | KINESIS_RESOURCE_NOT_FOUND | KINESIS_PROVISIONED_THROUGHPUT_EXCEEDED | KMS_ACCESS_DENIED | KMS_NOT_FOUND | KMS_DISABLED | KMS_INVALID_STATE | KMS_THROTTLING` errorMessage + Die ausführliche Fehlermeldung + Typ: Zeichenfolge eventId + Die eindeutige Ereignis-ID, die jedem Messexport entspricht + Typ: Zeichenfolge eventType + Der aktuelle Ereignistyp + Typ: Zeichenfolge + Gültige Werte: `measurement` ` | gatewayConnected` ` | gatewayDisconnected` ` | sensorConnected` ` | sensorDisconnected` ` | assetStateTransition` Positionsname + Der Name der Sensorposition, der in der App angezeigt wird + Typ: Zeichenfolge projectName + Der in der App und der Konsole angezeigte Projektname + Typ: Zeichenfolge Projekt-ID + Die eindeutige Projekt-ID, die dem Amazon Monitron Monitron-Projekt entspricht + Typ: Zeichenfolge Sensor-ID + Die physische ID des Sensors, von dem die Messung gesendet wird + Typ: Zeichenfolge Gateway-ID + Die physische ID des Gateways, das zur Übertragung von Daten an den Amazon Monitron-Service verwendet wird + Typ: Zeichenfolge siteName + Der Name der Site, der in der App angezeigt wird + Typ: Zeichenfolge Zeitstempel + Der Zeitstempel, zu dem die Messung vom Amazon Monitron-Service in UTC empfangen wird + Typ: Zeichenfolge + Muster: hh:mm:ss.sss yyyy-mm-dd # Speichern exportierter Daten in Amazon S3 Wenn Sie Ihre exportierten Daten in Amazon S3 speichern möchten, gehen Sie wie folgt vor. **Topics** + [Manuelles Konfigurieren von Kinesis in der Konsole](#kinesis-configure-console-v2) ## Manuelles Konfigurieren von Kinesis in der Konsole 1. Melden Sie sich bei der AWS Management Console an und öffnen Sie die Kinesis-Konsole unter https://console.aws.amazon.com /kinesis. 1. Wählen Sie im Navigationsbereich **Delivery Streams** aus. 1. Wählen Sie **Create Delivery Stream (Bereitstellungs-Stream erstellen)** aus. 1. Wählen Sie als Quelle **Amazon Kinesis Data Streams** aus. 1. Wählen Sie als Ziel **Amazon S3** aus. 1. Geben Sie unter **Quelleinstellungen, Kinesis-Datenstrom** den ARN Ihres Kinesis-Datenstroms ein. 1. Geben Sie unter **Delivery Stream Name** den Namen Ihres Kinesis-Datenstreams ein. 1. Wählen Sie **unter Zieleinstellungen** einen Amazon S3 S3-Bucket aus oder geben Sie einen Bucket-URI ein. 1. (optional) Aktivieren Sie die dynamische Partitionierung mithilfe von Inline-Parsing für JSON. Diese Option ist geeignet, wenn Sie Streaming-Messdaten auf der Grundlage von Quellinformationen und Zeitstempel partitionieren möchten. Beispiel: + Wählen Sie **Aktiviert** für **dynamische Partitionierung**. + Wählen Sie für **Neues Zeilentrennzeichen** **die Option Aktiviert** aus. + Wählen Sie **Aktiviert** für **Inline-Parsing** für JSON. + Fügen Sie unter **Dynamische Partitionierungsschlüssel Folgendes hinzu**: [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/kinesis-store-S3-v2.html) 1. Wählen Sie **Apply dynamic partitioning keys** und vergewissern Sie sich, dass das generierte Amazon S3 S3-Bucket-Präfix aktiviert ist`!{partitionKeyFromQuery:project}/!{partitionKeyFromQuery:site}/!{partitionKeyFromQuery:time}/`. 1. In Amazon S3 verwenden Objekte das folgende Schlüsselformat:`/project={projectName}/site={siteName}/time={yyyy-mm-dd 00:00:00}/{filename}`. 1. Wählen Sie **Create Delivery Stream (Bereitstellungs-Stream erstellen)** aus. # Daten mit Lambda verarbeiten **Topics** + [Schritt 1: Erstellen Sie die [IAM-Rolle](https://docs.aws.amazon.com//lambda/latest/dg/lambda-intro-execution-role.html), die Ihrer Funktion die Erlaubnis erteilt, auf Ressourcen zuzugreifen AWS](#data-export-lambda-v2-1) + [Schritt 2: Erstellen Sie die Lambda-Funktion](#create-lambda-function-v2) + [Schritt 3: Lambda-Funktion konfigurieren](#configure-lambda-function-v2) + [Schritt 4: Kinesis-Trigger in der AWS Lambda Konsole aktivieren](#configure-kinesis-trigger-v2) ## Schritt 1: Erstellen Sie die [IAM-Rolle](https://docs.aws.amazon.com//lambda/latest/dg/lambda-intro-execution-role.html), die Ihrer Funktion die Erlaubnis erteilt, auf Ressourcen zuzugreifen AWS 1. Öffnen Sie die Seite [Roles (Rollen)](https://console.aws.amazon.com/iam/home?#/roles) in der IAM-Konsole. 1. Wählen Sie **Rolle erstellen** aus. 1. Gehen Sie auf der Seite **Select trusted entity** (Vertrauenswürdige Entität auswählen) wie folgt vor: + Wählen Sie unter **Vertrauenswürdiger Entitätstyp** die Option **AWS Dienst** aus. + Wählen **Sie unter Anwendungsfall** für **Service oder Anwendungsfall** **Lambda** aus. + Wählen Sie **Weiter** aus. ![\[IAM role creation interface showing trusted entity selection with AWS-Service option chosen.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/lambda-role-1.png) 1. Gehen Sie auf der Seite „**Berechtigungen hinzufügen**“ wie folgt vor: + Wählen Sie unter **Berechtigungsrichtlinien** die Option aus AWSLambda KinesisExecutionRole (und AWSKey ManagementServicePowerUser ob der Kinesis-Stream verschlüsselt ist). + Lassen Sie die Konfigurationen unter **Berechtigungsgrenze festlegen** unverändert. + Wählen Sie **Weiter** aus. ![\[Add permissions interface showing AWSLambdaKinesisExecutionRole policy selected for a new role.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/lambda-role-2.png) 1. Gehen Sie auf der Seite **Name, Überprüfung und Erstellung** wie folgt vor: + Geben Sie **unter Rollendetails** für **Rollenname** einen Namen für Ihre Rolle ein. Zum Beispiel *lambda-kinesis-role*. Sie können sich auch dafür entscheiden, eine optionale **Beschreibung** hinzuzufügen. + Belassen Sie die Einstellungen für **Schritt 1: Vertrauenswürdige Entitäten auswählen** und **Schritt 2: Berechtigungen hinzufügen** unverändert. In **Schritt 3: Stichwörter hinzufügen können Sie auswählen, ob Sie Tags hinzufügen** möchten, um den Überblick über Ihre Ressourcen zu behalten. ![\[IAM role creation interface showing name, review, and create steps with role details and permissions.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/lambda-create-role.png) 1. Wählen Sie **Create rule (Regel erstellen)** aus. ## Schritt 2: Erstellen Sie die Lambda-Funktion 1. Öffnen Sie die Seite **Funktionen** in der Lambda-Konsole. 1. Wählen Sie **Funktion erstellen**. 1. Wählen Sie **Use a blueprint (Vorlage verwenden)**. 1. Suchen Sie in der **Blueprints-Suchleiste** und wählen Sie **kinesis-process-record (nodejs**) oder. **kinesis-process-record-python** 1. Wählen Sie **Konfigurieren** aus. ![\[Create function interface with options to author from scratch, use a blueprint, or select container image.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/lambda-create-function.png) ## Schritt 3: Lambda-Funktion konfigurieren 1. Wählen Sie den **Funktionsnamen** 1. Wählen Sie die im ersten Schritt erstellte Rolle als **Ausführungsrolle** aus. 1. Konfigurieren Sie den Kinesis-Trigger. 1. Wählen Sie Ihren Kinesis-Stream. 1. Klicken Sie auf **Funktion erstellen**. ![\[Lambda function configuration form with basic information and Kinesis trigger settings.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/lambda-kinesis-trigger.png) ## Schritt 4: Kinesis-Trigger in der AWS Lambda Konsole aktivieren 1. Wählen Sie auf der Registerkarte **Konfiguration** die Option **Trigger aus**. 1. Markieren Sie das Kästchen neben dem Namen des Kinesis-Streams und wählen Sie **Aktivieren** aus. ![\[Lambda function configuration page with Triggers tab and Kinesis stream trigger highlighted.\]](http://docs.aws.amazon.com/de_de/Monitron/latest/user-guide/images/kinesis-process-record-lambda.png) Der in diesem Beispiel verwendete Blueprint verwendet nur Protokolldaten aus dem ausgewählten Stream. Sie können den Lambda-Funktionscode später weiter bearbeiten, um eine kompliziertere Aufgabe zu erledigen. # Grundlegendes zum v2-Datenexportschema Alle Messdaten, das entsprechende Inferenzergebnis und connect/disconnect, and sensor connect/disconnect Gateway-Ereignisse werden als ein einziger Kinesis-Datenstream-Datensatz im JSON-Format exportiert. **Topics** + [v2-Schemaformat](#data-export-schema-format-v2) + [v2-Schemaparameter](#data-export-schema-parameters-v2) ## v2-Schemaformat ``` { "timestamp": "string", "eventId": "string", "version": "2.0", "accountId": "string", "projectName": "string", "projectId": "string", "eventType": "measurement|gatewayConnected|gatewayDisconnected|sensorConnected|sensorDisconnected|assetStateTransition", // measurement "eventPayload": { "siteName": "string", "assetName": "string", "positionName": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "serialNumber": "string", "make": "string", "model": "string", "assetPositionURL": "string", "sensor": { "physicalId": "string", "rssi": number }, "gateway": { "physicalId": "string" }, "sequenceNo": number, "features": { "acceleration": { "band0To6000Hz": { "xAxis": { "rms": number }, "yAxis": { "rms": number }, "zAxis": { "rms": number } }, "band10To1000Hz": { "totalVibration": { "absMax": number, "absMin": number, "crestFactor": number, "rms": number }, "xAxis": { "rms": number }, "yAxis": { "rms": number }, "zAxis": { "rms": number } } }, "velocity": { "band10To1000Hz": { "totalVibration": { "absMax": number, "absMin": number, "crestFactor": number, "rms": number }, "xAxis": { "rms": number }, "yAxis": { "rms": number }, "zAxis": { "rms": number } } }, "temperature": number } "models": { "temperatureML": { "previousPersistentClassificationOutput": "string", "persistentClassificationOutput": "string", "pointwiseClassificationOutput": "string" }, "vibrationISO": { "isoClass": "string", "mutedThreshold": "string", "previousPersistentClassificationOutput": "string", "persistentClassificationOutput": "string", "pointwiseClassificationOutput": "string" }, "vibrationML": { "previousPersistentClassificationOutput": "string", "persistentClassificationOutput": "string", "pointwiseClassificationOutput": "string" } }, "assetPositionId": "string" } // sensorConnected "eventPayload": { "siteName": "string", "assetName": "string", "positionName": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "serialNumber": "string", "make": "string", "model": "string", "assetPositionURL": "string", "sensor": { "physicalId": "string" }, "assetPositionId": "string" } // sensorDisconnected "eventPayload": { "siteName": "string", "assetName": "string", "positionName": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "serialNumber": "string", "make": "string", "model": "string", "assetPositionURL": "string", "sensor": { "physicalId": "string" }, "assetPositionId": "string" } // gatewayConnected "eventPayload": { "siteName": "string", "gatewayName": "string", "gatewayListURL": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "gateway": { "physicalId": "string" } } // gatewayDisconnected "eventPayload": { "siteName": "string", "gatewayName": "string", "gatewayListURL": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "gateway": { "physicalId": "string" } } // assetStateTransition "eventPayload": { "siteName": "string", "assetName": "string", "positionName": "string", "companyName": "string", "geoLocation": { "latitude": number, "longitude": number }, "address": "string", "serialNumber": "string", "make": "string", "model": "string", "assetPositionURL": "string", "sensor": { "physicalId": "string" }, "assetTransitionType": "measurement|userInput", "assetState": { "newState": "string", "previousState": "string" }, "closureCode": { "failureMode": "string", "failureCause": "string", "actionTaken": "string", "resolvedModels": list<"string"> }, "assetPositionId": "string" } } ``` ## v2-Schemaparameter Das Amazon Monitron Kinesis-Datenexportschema v2 umfasst die folgenden Schemaparameter. Bei einigen Parametern handelt es sich um Aktualisierungen von Version 1, andere nur für Version 2. `siteName`War beispielsweise ein Parameter der ersten Ebene in Version 1. In v2 handelt es sich um einen Parameter der zweiten Ebene, der sich unter der `eventPayload` Entität befindet. Zeitstempel + Der Zeitstempel, zu dem die Messung vom Amazon Monitron-Service in UTC empfangen wird + Typ: Zeichenfolge + Muster: hh:mm:ss.sss yyyy-mm-dd eventId + Die eindeutige Datenexportereignis-ID, die jeder Messung zugewiesen wurde. Kann verwendet werden, um die empfangenen Kinesis-Stream-Datensätze zu deduplizieren. + Typ: Zeichenfolge version + Schemaversion + Typ: Zeichenfolge + Wert: 1.0 oder 2.0 accountId + Die 12-stellige AWS Konto-ID für Ihr Monitron-Projekt + Typ: Zeichenfolge projectName Der Projektname, der in der App und der Konsole angezeigt wird. Typ: Zeichenfolge projectId Die eindeutige ID Ihres Amazon Monitron Projekts. Typ: Zeichenfolge eventType + Der aktuelle Event-Stream. Jeder Ereignistyp wird ein eigenes `eventPayload` Format haben. + Typ: Zeichenfolge + Mögliche Werte:`measurement`,`gatewayConnected`,`gatewayDisconnected`,`sensorConnected`,`sensorDisconnected`,`assetStateTransition`. **`eventType: measurement`** EventPayload.Features.Acceleration.Band0 bis 6000Hz.xaxis.rms + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 0—6000 Hz auf der X-Achse + Typ: Zahl + Einheit: m/s^2 EventPayload.Features.Acceleration.Band0 bis 6000 Hz.Yaxis.RMS + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 0—6000 Hz auf der Y-Achse + Typ: Zahl + Einheit: m/s^2 EventPayload.Features.Acceleration.Band0 bis 6000 Hz.Zaxis.RMS + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 0—6000 Hz auf der Z-Achse + Typ: Zahl + Einheit: m/s^2 EventPayload.Features.Beschleunigung.Band10 bis 1000 Hz. ResultantVector.ABSMax + Die absolute maximale Beschleunigung, die im Frequenzband 10—1000 Hz beobachtet wurde + Typ: Zahl + Einheit: m/s^2 EventPayload.Features.Acceleration.Band10 bis 1000 Hz. ResultantVector.ABSmin + Die absolute Mindestbeschleunigung, die im Frequenzband 10—1000 Hz beobachtet wurde + Typ: Zahl + Einheit: m/s^2 EventPayload.Features.Acceleration.Band10 bis 1000 Hz. ResultantVector.CrestFactor + Der im Frequenzband 10—1000 Hz beobachtete Beschleunigungs-Crest-Faktor + Typ: Zahl EventPayload.Features.Acceleration.Band10 bis 1000 Hz.ResultantVector.RMS + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 10—1000 Hz + Typ: Zahl + m/s^2 EventPayload.Features.Acceleration.Band10 bis 1000 Hz.xaxis.rms + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 10—1000 Hz auf der X-Achse + Typ: Zahl + m/s^2 EventPayload.Features.Acceleration.Band10 bis 1000 Hz.Yaxis.RMS + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 10—1000 Hz auf der Y-Achse + Typ: Zahl + m/s^2 EventPayload.Features.Acceleration.Band10 bis 1000 Hz.Zaxis.RMS + Der quadratische Mittelwert der beobachteten Beschleunigung im Frequenzband 10—1000 Hz auf der Z-Achse + Typ: Zahl + m/s^2 EventPayload.Features.Temperatur + Die beobachtete Temperatur + Typ: Zahl + °C/Grad C Nutzlast des Ereignisses. Funktionen. Geschwindigkeit. Band 10 bis 1000 Hz. Resultierender Vektor. ABS Max + Die absolute Höchstgeschwindigkeit, die im Frequenzband 10—1000 Hz beobachtet wurde + Typ: Zahl + mm/s Nutzlast des Ereignisses. Funktionen. Geschwindigkeit. Band 10 bis 1000 Hz. Resultierender Vektor. ABS min + Die absolute Mindestgeschwindigkeit, die im Frequenzband 10—1000 Hz beobachtet wurde + Typ: Zahl + mm/s EventPayload.Features.Velocity.Band10 bis 1000 Hz. Resultierender Vector.CrestFactor + Der im Frequenzband 10—1000 Hz beobachtete Geschwindigkeits-Crest-Faktor + Typ: Zahl EventPayload.Features.Velocity.Band10 bis 1000 Hz.ResultantVector.RMS + Der quadratische Mittelwert der im Frequenzband 10—1000 Hz beobachteten Geschwindigkeit + Typ: Zahl + mm/s EventPayload.Features.Velocity.Band10 bis 1000 Hz.xaxis.rms + Der quadratische Mittelwert der im Frequenzband 10—1000 Hz auf der X-Achse beobachteten Geschwindigkeit + Typ: Zahl + mm/s EventPayload.Features.Velocity.Band10 bis 1000 Hz.Yaxis.RMS + Der quadratische Mittelwert der im Frequenzband 10—1000 Hz auf der Y-Achse beobachteten Geschwindigkeit + Typ: Zahl + mm/s EventPayload.Features.Velocity.Band10 bis 1000 Hz.Zaxis.RMS + Der quadratische Mittelwert der im Frequenzband 10—1000 Hz auf der Z-Achse beobachteten Geschwindigkeit + Typ: Zahl + mm/s Nutzlast des Ereignisses. Sequenz Nein + Die Nummer der Messsequenz + Typ: Zahl Nutzlast des Ereignisses. assetPositionId + Die Kennung der Sensorposition, für die die Messung gesendet wird. + Typ: Zeichenfolge EventPayload.Firmenname + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge eventPayload.Seriennummer + Die Seriennummer des Assets. + Typ: Zeichenfolge eventPayload.Make + Die Marke des Vermögenswerts. + Typ: Zeichenfolge EventPayload.Model + Das Modell des Vermögenswerts. + Typ: Zeichenfolge `eventType: sensorConnected` siteName + Der Name der Site, der in der App angezeigt wird + Typ: Zeichenfolge Name des Vermögenswerts + Der in der App angezeigte Asset-Name + Typ: Zeichenfolge Positionsname + Der Name der Sensorposition, der in der App angezeigt wird + Typ: Zeichenfolge AssetPositionURL + Die in der App angezeigte Sensor-URL + Typ: Zeichenfolge Physische ID + Die physische ID des Sensors, von dem die Messung gesendet wird + Typ: Zeichenfolge Nutzlast des Ereignisses. assetPositionId + Die Kennung der Sensorposition, deren Zustand sich geändert hat. + Typ: Zeichenfolge eventPayload.CompanyName + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge eventPayload.Seriennummer + Die Seriennummer des Assets. + Typ: Zeichenfolge eventPayload.Make + Die Marke des Vermögenswerts. + Typ: Zeichenfolge EventPayload.Model + Das Modell des Vermögenswerts. + Typ: Zeichenfolge `eventType: sensorDisconnected` siteName + Der Name der Site, der in der App angezeigt wird + Typ: Zeichenfolge Name des Vermögenswerts + Der in der App angezeigte Asset-Name + Typ: Zeichenfolge Positionsname + Der Name der Sensorposition, der in der App angezeigt wird + Typ: Zeichenfolge AssetPositionURL + Die in der App angezeigte Sensor-URL + Typ: Zeichenfolge Physische ID + Die physische ID des Sensors, von dem die Messung gesendet wird + Typ: Zeichenfolge Nutzlast des Ereignisses. assetPositionId + Die Kennung der Sensorposition, deren Zustand sich geändert hat. + Typ: Zeichenfolge eventPayload.CompanyName + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge eventPayload.Seriennummer + Die Seriennummer des Assets. + Typ: Zeichenfolge eventPayload.Make + Die Marke des Vermögenswerts. + Typ: Zeichenfolge EventPayload.Model + Das Modell des Vermögenswerts. + Typ: Zeichenfolge `eventType: gatewayConnected` eventPayload.SiteName + Der Name der Site, der in der App angezeigt wird + Typ: Zeichenfolge eventPayload.GatewayName + Der Name des Gateways, wie er in der App angezeigt wird + Typ: Zeichenfolge eventPayload.GatewayListUrl + Die in der App angezeigte Gateway-URL + Typ: Zeichenfolge eventPayload.Gateway.PhysicAlid + Die physische ID des Gateways, mit dem gerade eine Verbindung hergestellt wurde, um Daten an den Amazon Monitron-Service zu übertragen + Typ: Zeichenfolge eventPayload.CompanyName + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge `eventType: gatewayDisconnected` siteName + Der in der App angezeigte Site-Name + Typ: Zeichenfolge Gateway-Name + Der Name des Gateways, wie er in der App angezeigt wird + Typ: Zeichenfolge GatewayListURL + Die in der App angezeigte Gateway-URL + Typ: Zeichenfolge Physische ID + Die physische ID des Gateways, mit dem gerade eine Verbindung hergestellt wurde, um Daten an den Amazon Monitron-Service zu übertragen + Typ: Zeichenfolge eventPayload.CompanyName + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge `eventType: assetStateTransition` eventPayload.SiteName + Der Name der Site, der in der App angezeigt wird + Typ: Zeichenfolge eventPayload.AssetName + Der in der App angezeigte Asset-Name + Typ: Zeichenfolge eventPayload.PositionName + Der Name der Sensorposition, der in der App angezeigt wird + Typ: Zeichenfolge eventPayload.AssetPositionUrl + Die in der App angezeigte Sensor-URL + Typ: Zeichenfolge eventPayload.Sensor.PhysicAlid + Die physische ID des Sensors, von dem die Messung gesendet wird + Typ: Zeichenfolge Nutzlast des Ereignisses. assetTransitionType + Der Grund für den Übergang zum Vermögensstatus + Typ: Zeichenfolge + Mögliche Werte: `measurement` oder `userInput` eventPayload.AssetState.NewState + Der neue Status des Assets + Typ: Zeichenfolge eventPayload.AssetState.PreviousState + Der vorherige Status des Assets + Typ: Zeichenfolge EventPayload.ClosureCode.FailureMode + Der vom Benutzer bei der Bestätigung dieses Fehlers gewählte Fehlermodus + Typ: Zeichenfolge + Mögliche Werte: `NO_ISSUE` \$1 \$1 `BLOCKAGE` \$1 `CAVITATION` \$1 `CORROSION` \$1 `DEPOSIT` \$1 `IMBALANCE` \$1 `LUBRICATION` \$1 `MISALIGNMENT` \$1 \$1 `OTHER` \$1 `RESONANCE` \$1 `ROTATING_LOOSENESS` \$1 `STRUCTURAL_LOOSENESS` \$1 `TRANSMITTED_FAULT` `UNDETERMINED` eventPayload.ClosureCode.FailureCause + Die Ursache des Fehlers, wie sie vom Benutzer bei der Bestätigung eines Fehlers in der Dropdownliste der App ausgewählt wurde. + Typ: Zeichenfolge + Mögliche Werte: `ADMINISTRATION` \$1 \$1 `DESIGN` \$1 `FABRICATION` \$1 `MAINTENANCE` \$1 `OPERATION` \$1 `OTHER` \$1 `QUALITY` `UNDETERMINED` `WEAR` eventPayload.ClosureCode.actionTaken + Die Aktion, die beim Schließen dieser Anomalie ergriffen wurde, wie vom Benutzer in der App-Dropdown-Liste ausgewählt. + Typ: Zeichenfolge + Mögliche Werte: `ADJUST` \$1 \$1 `CLEAN` \$1 `LUBRICATE` \$1 `MODIFY` \$1 `NO_ACTION` \$1 `OTHER` `OVERHAUL` `REPLACE` eventPayload.ClosureCode.ResolvedModels + Die Modellgruppe, die auf das Problem hingewiesen hat. + Typ: Listen von Strings + Mögliche Werte: `vibrationISO` \$1 `vibrationML` \$1 `temperatureML` Payload des Ereignisses. assetPositionId + Die Kennung der Vermögensposition, deren Status sich geändert hat. + Typ: Zeichenfolge Models.TemperatureML. persistentClassificationOutput + Die persistente Klassifizierungsausgabe des auf maschinellem Lernen basierenden Temperaturmodells + Typ: Zahl + Zulässige Werte: `UNKNOWN | HEALTHY | WARNING | ALARM` Models.TemperatureML. pointwiseClassificationOutput + Das Ergebnis der punktweisen Klassifizierung aus dem auf maschinellem Lernen basierenden Temperaturmodell + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | INITIALIZING | HEALTHY | WARNING | ALARM` models.vibrationiso.ISOClass + Die Klasse ISO 20816 (ein Standard für die Messung und Bewertung von Maschinenschwingungen), die vom ISO-basierten Schwingungsmodell verwendet wird + Typ: Zeichenfolge + Zulässige Werte: `CLASS1 | CLASS2 | CLASS3 | CLASS4` Models.VibrationISO.MutedThreshold + Der Schwellenwert für das Stummschalten der Benachrichtigung aus dem ISO-basierten Schwingungsmodell + Typ: Zeichenfolge + Zulässige Werte: `WARNING | ALARM` Models.VibrationISO. persistentClassificationOutput + Das Ergebnis des ISO-basierten Schwingungsmodells anhand der dauerhaften Klassifizierung + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | HEALTHY | WARNING | ALARM` Models.VibrationISO. pointwiseClassificationOutput + Das Ergebnis der punktweisen Klassifizierung aus dem ISO-basierten Schwingungsmodell + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | HEALTHY | WARNING | ALARM | MUTED_WARNING | MUTED_ALARM` Models.VibrationML. persistentClassificationOutput + Das persistente Klassifikationsergebnis des auf maschinellem Lernen basierenden Schwingungsmodells + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | HEALTHY | WARNING | ALARM` Models.VibrationML. pointwiseClassificationOutput + Das Ergebnis der punktweisen Klassifikation aus dem auf maschinellem Lernen basierenden Schwingungsmodell + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | INITIALIZING | HEALTHY | WARNING | ALARM` AssetState.NewState + Der Maschinenstatus nach der Verarbeitung der Messung + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | HEALTHY | NEEDS_MAINTENANCE | WARNING | ALARM` Anlagenstatus. Voriger Zustand + Der Maschinenstatus vor der Verarbeitung der Messung + Typ: Zeichenfolge + Zulässige Werte: `UNKNOWN | HEALTHY | NEEDS_MAINTENANCE | WARNING | ALARM` EventPayload.Firmenname + Der Name des Unternehmens, das das Asset verwendet. + Typ: Zeichenfolge eventPayload.Geolocation.Latitude + Der Breitengrad des physischen Standorts der Site. + Typ: Zahl eventPayload.Geolocation.Longitude + Der Längengrad des physischen Standorts der Site. + Typ: Zahl EventPayload.Address + Die Adresse der Website. + Typ: Zeichenfolge eventPayload.Seriennummer + Die Seriennummer des Assets. + Typ: Zeichenfolge eventPayload.Make + Die Marke des Vermögenswerts. + Typ: Zeichenfolge EventPayload.Model + Das Modell des Vermögenswerts. + Typ: Zeichenfolge # Migration von Kinesis v1 zu v2 Wenn Sie derzeit das v1-Datenschema verwenden, senden Sie möglicherweise bereits Daten an Amazon S3 oder verarbeiten die Datenstrom-Payload mit Lambda weiter. **Topics** + [Aktualisierung des Datenschemas auf Version 2](#updating-to-v2) + [Aktualisierung der Datenverarbeitung mit Lambda](#updating-with-lam) ## Aktualisierung des Datenschemas auf Version 2 Wenn Sie bereits einen Datenstream mit dem v1-Schema konfiguriert haben, können Sie Ihren Datenexportprozess wie folgt aktualisieren: 1. Öffnen Sie Ihre Amazon Monitron Monitron-Konsole. 1. Navigieren Sie zu Ihrem Projekt. 1. Stoppen Sie den [aktuellen Live-Datenexport](monitron-kinesis-export-v2.md#stop-kinesis-export-v2). 1. Starten Sie den Live-Datenexport, um einen neuen Datenstrom zu erstellen. 1. Wählen Sie den neu erstellten Datenstrom aus. 1. Wählen Sie **Live-Datenexport starten**. Zu diesem Zeitpunkt sendet das neue Schema Ihre Nutzdaten durch den Datenstrom. 1. (Optional) Gehen Sie zur Kinesis-Konsole und löschen Sie Ihren alten Datenstream. 1. Konfigurieren Sie eine neue Bereitstellungsmethode für Ihren neu erstellten Datenstream mit dem v2-Schema. Ihr neuer Stream liefert jetzt Payloads, die dem v2-Schema entsprechen, an Ihren neuen Bucket. Wir empfehlen, zwei unterschiedliche Buckets zu verwenden, um ein einheitliches Format zu haben, falls Sie alle Daten in diesen Buckets verarbeiten möchten. Zum Beispiel die Nutzung anderer Dienste wie Athena und AWS Glue. **Anmerkung** Wenn Sie Ihre Daten an Amazon S3 übermittelt haben, erfahren Sie, wie Sie [exportierte Daten in Amazon S3 speichern](kinesis-store-S3-v2.md#kinesis-store-S3-title-v2), um weitere Informationen zur Übertragung Ihrer Daten an Amazon S3 mit dem v2-Schema zu erhalten. **Anmerkung** Wenn Sie eine Lambda-Funktion zur Verarbeitung Ihrer Payloads verwendet haben, erfahren Sie, wie Sie [Daten mit Lambda verarbeiten](https://docs.aws.amazon.com/Monitron/latest/user-guide/data-export-lambda.html). Weitere Informationen finden Sie auch im Abschnitt [Aktualisierung mit Lambda](#updating-with-lam). ## Aktualisierung der Datenverarbeitung mit Lambda Um die Datenverarbeitung mit Lambda zu aktualisieren, müssen Sie berücksichtigen, dass der v2-Datenstrom jetzt ereignisbasiert ist. Ihr erster v1-Lambda-Code sah möglicherweise dem folgenden ähnlich: ``` import base64 def main_handler(event): # Kinesis "data" blob is base64 encoded so decode here: for record in event['Records']: payload = base64.b64decode(record["kinesis"]["data"]) measurement = payload["measurement"] projectDisplayName = payload["projectDisplayName"] # Process the content of the measurement # ... ``` Da sich das v1-Datenschema auf einem veralteten Pfad befindet, funktioniert der vorherige Lambda-Code nicht mit allen neuen Datenströmen. Der folgende Python-Beispielcode verarbeitet Ereignisse aus dem Kinesis-Stream mit dem Datenschema v2. Dieser Code verwendet den neuen `eventType` Parameter, um die Verarbeitung auf den entsprechenden Handler auszurichten: ``` import base64 handlers = { "measurement": measurementEventHandler, "gatewayConnected": gatewayConnectedEventHandler, "gatewayDisconnected": gatewayDisconnectedEventHandler, "sensorConnected": sensorConnectedEventHandler, "sensorDisconnected": sensorDisconnectedEventHandler, } def main_handler(event): # Kinesis "data" blob is base64 encoded so decode here: for record in event['Records']: payload = base64.b64decode(record["kinesis"]["data"]) eventType = payload["eventType"] if eventType not in handler.keys(): log.info("No event handler found for the event type: {event['eventType']}") return # Invoke the appropriate handler based on the event type. eventPayload = payload["eventPayload"] eventHandler = handlers[eventType] eventHandler(eventPayload) def measurementEventHandler(measurementEventPayload): # Handle measurement event projectName = measurementEventPayload["projectName"] # ... def gatewayConnectedEventHandler(gatewayConnectedEventPayload): # Handle gateway connected event # Other event handler functions ```