Freigeben über

Der Befehl „.ingest-from-storage-queued“

Wechseln Von Diensten mithilfe der Dropdownliste "Version ". Weitere Informationen zur Navigation.
Gilt für: ✅ Microsoft Fabric ✅ Azure Data Explorer

Der .ingest-from-storage-queued Befehl wird verwendet, um Blobs für die Aufnahme in eine Tabelle in die Warteschlange zu stellen. Sie unterstützt die Erfassung einzelner Blobs nach URL, mehreren Blobs aus einer Quelldatei, bestimmten Ordnern oder einem gesamten Speichercontainer. Dieser Befehl eignet sich zum Testen und Verwalten von Aufnahmeszenarien, um sicherzustellen, dass Schema, Partitionierung und andere Konfigurationen ordnungsgemäß angewendet werden.

Note

Diese Aufnahmemethode ist für Die Erforschung und Prototyperstellung vorgesehen. Verwenden Sie sie nicht in Produktions- oder Volumenszenarien.

Note

Diese Aufnahmemethode ist für Die Erforschung und Prototyperstellung vorgesehen. Verwenden Sie sie nicht in Produktions- oder Volumenszenarien. Weitere Informationen zu Aufnahmeoptionen finden Sie unter Datenaufnahmeübersicht.

Note

In die Warteschlange eingereihte Aufnahmebefehle werden auf dem Datenaufnahme-URI-Endpunkt https://ingest-<YourClusterName><Region>.kusto.windows.netausgeführt.

Permissions

Sie müssen mindestens über Die Berechtigungen "Table Ingestor " verfügen, um diesen Befehl auszuführen.

Syntax

.ingest-from-storage-queued into table[database(DatabaseName).]TableName[EnableTracking=EnableTracking] [SkipBatching=SkipBatching] [CompressionFactor] [=with (IngestionPropertyName = IngestionPropertyValue [, ...])] <|IngestionSource

Erfahren Sie mehr über Syntaxkonventionen.

Parameters

Name Type Required Description
DatabaseName string ✔️ Der Name der Datenbank, in die Daten aufgenommen werden sollen. Wenn kein Datenbankname angegeben wird, wird die Kontextdatenbank der Anforderung verwendet.
TableName string ✔️ Der Name der Tabelle, in die Daten aufgenommen werden sollen.
EnableTracking boolean Bestimmt, ob die Blob-Erfassung nachverfolgt werden soll. Weitere Informationen finden Sie unter Befehl "In die Warteschlange eingereihte Aufnahmevorgänge". Der Standardwert ist false.
SkipBatching boolean Wenn diese Eigenschaft auf truefestgelegt ist, werden die Blobs einzeln aufgenommen, anstatt zusammen mit anderen Blobs in batchediert zu werden. Der Standardwert ist false.
CompressionFactor real Der Komprimierungsfaktor (Verhältnis) zwischen der ursprünglichen Größe und der komprimierten Größe von Blobs. Der Komprimierungsfaktor wird verwendet, um die ursprüngliche Größe der Daten für Batchverarbeitungszwecke zu schätzen, wenn Blobs in einem komprimierten Format bereitgestellt werden.
IngestionPropertyName, IngestionPropertyValue string Optionale Aufnahmeeigenschaften. Weitere Informationen zu Aufnahmeeigenschaften finden Sie unter Datenaufnahmeeigenschaften.
IngestionSource string ✔️ Die Aufnahmequelle. Die Quelle kann BLOB-URL(n) (Vorschau) oder eine Liste von Blobs sein, die mit dem Befehl ".list blobs " zurückgegeben werden.

Note

Der befehl .list blobs kann mit dem Befehl .ingest-from-storage-queued verwendet werden, um die Blobs zurückzugeben, die Sie aufnehmen möchten. Ausführliche Informationen zum Befehl und einer vollständigen Liste seiner Parameter finden Sie unter .list blobs command.

Returns

Das Ergebnis des Befehls ist eine Tabelle mit einer Zeile und einer Spalte.

Name Type Description
IngestionOperationId string Eine eindeutige ID, die verwendet wird, um den Satz von Blobs nachzuverfolgen, unabhängig davon, ob die Nachverfolgung aktiviert ist.
ClientRequestId string Die Clientanforderungs-ID des Befehls.
OperationInfo string Zeigt den Befehl an, der ausgeführt werden soll, um den aktuellen Status des Vorgangs abzurufen.

Note

Mit diesem Befehl wird das Schema der Zieltabelle nicht geändert. Bei Bedarf werden die Daten während der Aufnahme in das Schema der Tabelle konvertiert. Zusätzliche Spalten werden ignoriert, und fehlende Spalten werden als NULL-Werte behandelt.

Examples

Die Beispiele in diesem Abschnitt zeigen, wie Sie die Syntax verwenden, um Ihnen den Einstieg zu erleichtern.

Aufnehmen von Blobs aus Dateien (Vorschau)

Im folgenden Beispiel werden Blobs aus Quelldateien in die Warteschlange gestellt.

.ingest-from-storage-queued into table database ('MyDatabase').mytable
EnableTracking=true
with (
  format='csv',
  ingestionMappingReference='MyMapping'
)
<| 'https://https://sample.blob.core.windows.net/sample/test_1.csv?...'
   'https://https://sample.blob.core.windows.net/sample/test_2.csv?...'
   'https://https://sample.blob.core.windows.net/sample/test_3.csv?...'

Note

Stellen Sie sicher, dass Sie ein SAS-Token einschließen oder eine verwaltete Identität verwenden, um dem Dienst die Berechtigung zum Zugriff und Herunterladen des BLOB zu erteilen. Weitere Informationen finden Sie unter Speicherverbindungszeichenfolgen .

Aufnehmen aller Blobs in einem Ordner

Im folgenden Beispiel werden alle Blobs innerhalb eines Ordners für die Aufnahme mithilfe der vom System verwalteten Identität des Clusters in die Warteschlange gestellt.

.ingest-from-storage-queued into table database('LogDb').RawLogs
EnableTracking=true
with (
  format='csv',
  ingestionMappingReference='LogMapping',
  ignoreFirstRecord=false  
)
<|
  .list blobs (
      "https://mystorageaccount.blob.core.windows.net/datasets/myfolder;managed_identity=system"
  )

Verwandte Inhalte

  • Last updated on