Feedback

az stream-analytics input

  • Referenz

Hinweis

Diese Referenz ist Teil der Streamanalyseerweiterung für die Azure CLI (Version 2.15.0 oder höher). Die Erweiterung installiert automatisch beim ersten Ausführen eines Az-Stream-Analytics-Eingabebefehls . Weitere Informationen zu Erweiterungen

Verwalten von Eingaben mit Datenstromanalysen.

Befehle

az stream-analytics input create

Erstellen Sie eine Eingabe oder ersetzt eine bereits vorhandene Eingabe unter einem vorhandenen Streamingauftrag.
az stream-analytics input delete

Löschen sie eine Eingabe aus dem Streamingauftrag.
az stream-analytics input list

Listet alle Eingaben unter dem angegebenen Streamingauftrag auf.
az stream-analytics input show

Rufen Sie Details zur angegebenen Eingabe ab.
az stream-analytics input test

Testen Sie, ob die Datenquelle einer Eingabe erreichbar und vom Azure Stream Analytics-Dienst verwendet werden kann.
az stream-analytics input update

Aktualisieren sie eine vorhandene Eingabe unter einem vorhandenen Streamingauftrag. Dies kann zum teilweisen Aktualisieren (ie. Aktualisieren einer oder zwei Eigenschaften) einer Eingabe verwendet werden, ohne den Rest der Auftrags- oder Eingabedefinition zu beeinträchtigen.
az stream-analytics input wait

Platzieren Sie die CLI in einem Wartezustand, bis eine Bedingung der Datenstromanalyseeingabe erfüllt ist.

az stream-analytics input create

Erstellen Sie eine Eingabe oder ersetzt eine bereits vorhandene Eingabe unter einem vorhandenen Streamingauftrag.

az stream-analytics input create --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

Beispiele

Erstellen einer Referenz-Blob-Eingabe mit CSV-Serialisierung

az stream-analytics input create --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Erstellen einer Stream-Event Hub-Eingabe mit JSON-Serialisierung

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"eventHubName\":\"sdkeventhub\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"someSharedAccessPolicyKey==\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Erstellen eines Datenstroms IoT Hub Eingabe mit Avro-Serialisierung

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"endpoint\":\"messages/events\",\"iotHubNamespace\":\"iothub\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"owner\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Erstellen einer Stream-Blob-Eingabe mit CSV-Serialisierung

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"sourcePartitionCount\":16,\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--if-match

Das ETag der Eingabe. Lassen Sie diesen Wert aus, um die aktuelle Eingabe immer zu überschreiben. Geben Sie den zuletzt gesehenen ETag-Wert an, um versehentlich das Überschreiben gleichzeitiger Änderungen zu verhindern.

--if-none-match

Legen Sie auf '*' fest, damit eine neue Eingabe erstellt werden kann, aber um die Aktualisierung einer vorhandenen Eingabe zu verhindern. Andere Werte führen zu einer 412 Vorbedingung fehlgeschlagenen Antwort.

--properties

Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace). Erwarteter Wert: json-string/json-file/@json-file.

az stream-analytics input delete

Löschen sie eine Eingabe aus dem Streamingauftrag.

az stream-analytics input delete --input-name
                                 --job-name
                                 --resource-group
                                 [--yes]

Beispiele

Löschen einer Eingabe

az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--yes -y

Nicht zur Bestätigung auffordern

az stream-analytics input list

Listet alle Eingaben unter dem angegebenen Streamingauftrag auf.

az stream-analytics input list --job-name
                               --resource-group
                               [--select]

Beispiele

Alle Eingaben in einem Streamingauftrag auflisten

az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"

Alle Eingaben in einem Streamingauftrag auflisten und Diagnoseinformationen mithilfe des $select OData-Abfrageparameters einschließen

az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"

Erforderliche Parameter

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--select

Der $select OData-Abfrageparameter. Dies ist eine durch Trennzeichen getrennte Liste der strukturellen Eigenschaften, die in die Antwort einbezogen werden sollen, oder "*", um alle Eigenschaften einzuschließen. Standardmäßig werden alle Eigenschaften mit Ausnahme der Diagnose zurückgegeben. Derzeit akzeptiert '*' nur als gültiger Wert.

az stream-analytics input show

Rufen Sie Details zur angegebenen Eingabe ab.

az stream-analytics input show --input-name
                               --job-name
                               --resource-group

Beispiele

Abrufen einer Referenz-BLOB-Eingabe mit CSV-Serialisierung

az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Abrufen einer Stream Event Hub-Eingabe mit JSON-Serialisierung

az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Abrufen eines Datenstroms IoT Hub Eingabe mit Avro-Serialisierung

az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Abrufen einer Stream-Blob-Eingabe mit CSV-Serialisierung

az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

az stream-analytics input test

Testen Sie, ob die Datenquelle einer Eingabe erreichbar und vom Azure Stream Analytics-Dienst verwendet werden kann.

az stream-analytics input test --input-name
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

Beispiele

Testen der Verbindung für eine Eingabe

az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--no-wait

Nicht auf den Abschluss lang andauernder Vorgänge warten

--properties

Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace). Erwarteter Wert: json-string/json-file/@json-file.

az stream-analytics input update

Aktualisieren sie eine vorhandene Eingabe unter einem vorhandenen Streamingauftrag. Dies kann zum teilweisen Aktualisieren (ie. Aktualisieren einer oder zwei Eigenschaften) einer Eingabe verwendet werden, ohne den Rest der Auftrags- oder Eingabedefinition zu beeinträchtigen.

az stream-analytics input update --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--properties]

Beispiele

Aktualisieren einer Referenz-BLOB-Eingabe

az stream-analytics input update --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Aktualisieren einer Stream-Event Hub-Eingabe

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"differentConsumerGroupName\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Aktualisieren eines Datenstroms IoT Hub Eingabe

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"endpoint\":\"messages/operationsMonitoringEvents\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Aktualisieren einer Stream-BLOB-Eingabe

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"sourcePartitionCount\":32}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--if-match

Das ETag der Eingabe. Lassen Sie diesen Wert aus, um die aktuelle Eingabe immer zu überschreiben. Geben Sie den zuletzt gesehenen ETag-Wert an, um versehentlich das Überschreiben gleichzeitiger Änderungen zu verhindern.

--properties

Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace). Erwarteter Wert: json-string/json-file/@json-file.

az stream-analytics input wait

Platzieren Sie die CLI in einem Wartezustand, bis eine Bedingung der Datenstromanalyseeingabe erfüllt ist.

az stream-analytics input wait --input-name
                               --job-name
                               --resource-group
                               [--created]
                               [--custom]
                               [--deleted]
                               [--exists]
                               [--interval]
                               [--timeout]
                               [--updated]

Beispiele

Anhalten der Ausführung der nächsten Zeile des CLI-Skripts, bis die Datenstromanalyseeingabe erfolgreich erstellt wird.

az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created

Erforderliche Parameter

--input-name --name -n

Der Name der Eingabe.

--job-name

Der Name des Streamingauftrags.

--resource-group -g

Name der Ressourcengruppe Sie können die Standardgruppe mit az configure --defaults group=<name> konfigurieren.

Optionale Parameter

--created

Warten Sie, bis Sie mit "provisioningState" unter "Erfolgreich" erstellt wurden.

--custom

Warten Sie, bis die Bedingung eine benutzerdefinierte JMESPath-Abfrage erfüllt. Beispiel: provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Warten Sie, bis sie gelöscht wurde.

--exists

Warten Sie, bis die Ressource vorhanden ist.

--interval

Abfrageintervall in Sekunden.

Standardwert: 30
--timeout

Maximale Wartezeit in Sekunden.

Standardwert: 3600
--updated

Warten Sie, bis die Aktualisierung mit provisioningState unter "Erfolgreich" ausgeführt wurde.