Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Definizione di risorsa Bicep
Il tipo di risorsa instances/dataflowProfiles/dataflows può essere distribuito con operazioni destinate a:
Per un elenco delle proprietà modificate in ogni versione dell'API, vedere log delle modifiche.
Formato risorsa
Per creare una risorsa Microsoft.IoTOperations/instances/dataflowProfiles/dataflows, aggiungere il bicep seguente al modello.
resource symbolicname 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2026-07-01' = {
parent: resourceSymbolicName
extendedLocation: {
name: 'string'
type: 'string'
}
name: 'string'
properties: {
mode: 'string'
operations: [
{
builtInTransformationSettings: {
datasets: [
{
description: 'string'
expression: 'string'
inputs: [
'string'
]
key: 'string'
schemaRef: 'string'
}
]
filter: [
{
description: 'string'
expression: 'string'
inputs: [
'string'
]
type: 'string'
}
]
map: [
{
description: 'string'
expression: 'string'
inputs: [
'string'
]
output: 'string'
type: 'string'
}
]
schemaRef: 'string'
serializationFormat: 'string'
}
destinationSettings: {
dataDestination: 'string'
endpointRef: 'string'
headers: [
{
actionType: 'string'
// For remaining properties, see DataflowDestinationHeaderAction objects
}
]
}
name: 'string'
operationType: 'string'
sourceSettings: {
assetRef: 'string'
dataSources: [
'string'
]
endpointRef: 'string'
schemaRef: 'string'
serializationFormat: 'string'
}
}
]
requestDiskPersistence: 'string'
}
}
Oggetti DataflowDestinationHeaderAction
Impostare la proprietà actionType per specificare il tipo di oggetto.
Per AddIfNotPresent, utilizzare:
{
actionType: 'AddIfNotPresent'
key: 'string'
value: 'string'
}
Per AddOrReplace, utilizzare:
{
actionType: 'AddOrReplace'
key: 'string'
value: 'string'
}
Per Rimuovere, utilizzare:
{
actionType: 'Remove'
key: 'string'
}
Valori delle proprietà
Microsoft.IoTOperations/instances/dataflowProfiles/dataflows
| Name | Description | Value |
|---|---|---|
| extendedLocation | Posizione perimetrale della risorsa. | ExtendedLocation |
| name | Nome della risorsa | string Constraints: Lunghezza minima = 3 Lunghezza massima = 63 Pattern = ^[a-z0-9][a-z0-9-]*[a-z0-9]$ (obbligatorio) |
| parent | In Bicep è possibile specificare la risorsa padre per una risorsa figlio. È necessario aggiungere questa proprietà solo quando la risorsa figlio viene dichiarata all'esterno della risorsa padre. Per altre informazioni, vedere risorsa figlio all'esterno della risorsa padre. |
Nome simbolico per la risorsa di tipo: instances/dataflowProfiles |
| properties | Proprietà specifiche della risorsa. | DataflowProperties |
DataflowBuiltInTransformationDataset
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del set di dati. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per arricchire i dati dall'archivio stati broker. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | string |
| inputs | Elenco di campi per l'arricchimento da Archivio stati broker. | string[] (obbligatorio) |
| key | Chiave del set di dati. | string Constraints: Lunghezza massima = 64 (obbligatorio) |
| schemaRef | Riferimento allo schema che descrive il set di dati. Consentito: schema JSON/bozza-7. | string |
DataflowBuiltInTransformationFilter
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del filtro. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per filtrare i dati. Può fare riferimento ai campi di input con {n} dove n è l'indice del campo di input a partire da 1. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | stringa (obbligatorio) |
| inputs | Elenco di campi per il filtro nell'espressione di percorso JSON. | string[] (obbligatorio) |
| type | Tipo di operazione del flusso di dati. | 'Filter' |
DataflowBuiltInTransformationMap
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa della funzione di mapping. | string Constraints: Lunghezza massima = 256 |
| expression | Modificare i campi di input nel campo di output finale. Esempio: $1 * 2,2 (presupponendo che venga fornita la sezione $1) | string |
| inputs | Elenco di campi per il mapping nell'espressione di percorso JSON. | string[] (obbligatorio) |
| output | Dove e come organizzare i campi di input nel record di output. | stringa (obbligatorio) |
| type | Tipo di trasformazione. | 'BuiltInFunction' 'Compute' 'NewProperties' 'PassThrough' 'Rename' |
DataflowBuiltInTransformationSettings
| Name | Description | Value |
|---|---|---|
| datasets | Arricchire i dati dall'archivio stati broker. Il set di dati fa riferimento a una chiave nell'archivio stati di Broker. | DataflowBuiltInTransformationDataset[] |
| filter | Filtra i record di input o i punti dati in base alla condizione. | DataflowBuiltInTransformationFilter[] |
| map | Esegue il mapping dell'input al messaggio di output. | DataflowBuiltInTransformationMap[] |
| schemaRef | Riferimento allo schema che descrive l'output della trasformazione. | string |
| serializationFormat | Formato di serializzazione. Opzionale; il valore predefinito è JSON. Valore consentito JSON Schema/draft-7, Parquet. Impostazione predefinita: Json | 'Delta' 'Json' 'Parquet' |
DataflowDestinationAddIfNotPresentHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddIfNotPresent' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere. | stringa (obbligatorio) |
DataflowDestinationAddOrReplaceHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddOrReplace' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
DataflowDestinationHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Impostare su 'AddIfNotPresent' per il tipo DataflowDestinationAddIfNotPresentHeaderAction. Impostare su 'AddOrReplace' per il tipo DataflowDestinationAddOrReplaceHeaderAction. Impostare su 'Rimuovi' per il tipo DataflowDestinationRemoveHeaderAction. | 'AddIfNotPresent' 'AggiungiOrSostituisci' 'Rimuovi' (obbligatorio) |
DataflowDestinationOperationSettings
| Name | Description | Value |
|---|---|---|
| dataDestination | Il percorso di destinazione può essere un argomento o un nome di tabella. Supporta valori dinamici con $topic, $systemProperties, $userProperties, $payload, $context e $subscription. | string Constraints: Lunghezza minima = 1 (obbligatorio) |
| endpointRef | Riferimento all'endpoint CR. Può essere di tipo Broker, Kafka, Fabric, ADLS, ADX. | stringa (obbligatorio) |
| headers | Intestazioni per i dati di output. | DataflowDestinationHeaderAction[] |
DataflowDestinationRemoveHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'Rimuovi' (obbligatorio) |
| key | Nome dell'intestazione da rimuovere. | stringa (obbligatorio) |
DataflowOperation
| Name | Description | Value |
|---|---|---|
| builtInTransformationSettings | Configurazione della trasformazione predefinita. | DataflowBuiltInTransformationSettings |
| destinationSettings | Configurazione della destinazione. | DataflowDestinationOperationSettings |
| name | Nome facoltativo fornito dall'utente della trasformazione. | string Constraints: Lunghezza massima = 64 |
| operationType | Tipo di operazione. | 'BuiltInTransformation' 'Destination' 'Fonte' (obbligatorio) |
| sourceSettings | Configurazione dell'origine. | DataflowSourceOperationSettings |
DataflowProperties
| Name | Description | Value |
|---|---|---|
| mode | Modalità per flusso di dati. Opzionale; il valore predefinito è Abilitato. | 'Disabled' 'Enabled' |
| operations | Elenco di operazioni, inclusi i riferimenti all'origine e alla destinazione, nonché la trasformazione. | DataflowOperation[] (obbligatorio) |
| requestDiskPersistence | Modalità di persistenza del disco. | 'Disabled' 'Enabled' |
DataflowSourceOperationSettings
| Name | Description | Value |
|---|---|---|
| assetRef | Riferimento alla risorsa in Registro dispositivi di Azure da cui provengono i dati nell'endpoint. | string |
| dataSources | Elenco delle posizioni di origine. Può essere broker o argomenti Kafka. Supporta i caratteri jolly # e +. | string Constraints: Lunghezza minima = 1[] (obbligatorio) |
| endpointRef | Riferimento alla risorsa endpoint flusso di dati. Può essere solo di tipo Broker e Kafka. | stringa (obbligatorio) |
| schemaRef | Riferimento cr dello schema. I dati verranno deserializzati in base allo schema e eliminati se non corrispondono. | string |
| serializationFormat | Il contenuto è uno schema JSON. Consentito: schema JSON/bozza-7. | 'Json' |
ExtendedLocation
| Name | Description | Value |
|---|---|---|
| name | Nome della posizione estesa. | stringa (obbligatorio) |
| type | Tipo di ExtendedLocation. | 'CustomLocation' (obbligatorio) |
Definizione di risorsa del modello di Resource Manager
Il tipo di risorsa instances/dataflowProfiles/dataflows può essere distribuito con operazioni destinate a:
- Gruppi di risorse - Vedi comandi di distribuzione dei gruppi di risorse Per un elenco delle proprietà modificate in ciascuna versione API, vedi registro delle modifiche.
Esempi di utilizzo
Formato risorsa
Per creare una risorsa Microsoft.IoTOperations/instances/dataflowProfiles/dataflows, aggiungere il codice JSON seguente al modello.
{
"type": "Microsoft.IoTOperations/instances/dataflowProfiles/dataflows",
"apiVersion": "2026-07-01",
"name": "string",
"extendedLocation": {
"name": "string",
"type": "string"
},
"properties": {
"mode": "string",
"operations": [
{
"builtInTransformationSettings": {
"datasets": [
{
"description": "string",
"expression": "string",
"inputs": [ "string" ],
"key": "string",
"schemaRef": "string"
}
],
"filter": [
{
"description": "string",
"expression": "string",
"inputs": [ "string" ],
"type": "string"
}
],
"map": [
{
"description": "string",
"expression": "string",
"inputs": [ "string" ],
"output": "string",
"type": "string"
}
],
"schemaRef": "string",
"serializationFormat": "string"
},
"destinationSettings": {
"dataDestination": "string",
"endpointRef": "string",
"headers": [ {
"actionType": "string"
// For remaining properties, see DataflowDestinationHeaderAction objects
} ]
},
"name": "string",
"operationType": "string",
"sourceSettings": {
"assetRef": "string",
"dataSources": [ "string" ],
"endpointRef": "string",
"schemaRef": "string",
"serializationFormat": "string"
}
}
],
"requestDiskPersistence": "string"
}
}
Oggetti DataflowDestinationHeaderAction
Impostare la proprietà actionType per specificare il tipo di oggetto.
Per AddIfNotPresent, utilizzare:
{
"actionType": "AddIfNotPresent",
"key": "string",
"value": "string"
}
Per AddOrReplace, utilizzare:
{
"actionType": "AddOrReplace",
"key": "string",
"value": "string"
}
Per Rimuovere, utilizzare:
{
"actionType": "Remove",
"key": "string"
}
Valori delle proprietà
Microsoft.IoTOperations/instances/dataflowProfiles/dataflows
| Name | Description | Value |
|---|---|---|
| apiVersion | Versione dell'API | '2026-07-01' |
| extendedLocation | Posizione perimetrale della risorsa. | ExtendedLocation |
| name | Nome della risorsa | string Constraints: Lunghezza minima = 3 Lunghezza massima = 63 Pattern = ^[a-z0-9][a-z0-9-]*[a-z0-9]$ (obbligatorio) |
| properties | Proprietà specifiche della risorsa. | DataflowProperties |
| type | Tipo di risorsa | 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows' |
DataflowBuiltInTransformationDataset
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del set di dati. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per arricchire i dati dall'archivio stati broker. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | string |
| inputs | Elenco di campi per l'arricchimento da Archivio stati broker. | string[] (obbligatorio) |
| key | Chiave del set di dati. | string Constraints: Lunghezza massima = 64 (obbligatorio) |
| schemaRef | Riferimento allo schema che descrive il set di dati. Consentito: schema JSON/bozza-7. | string |
DataflowBuiltInTransformationFilter
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del filtro. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per filtrare i dati. Può fare riferimento ai campi di input con {n} dove n è l'indice del campo di input a partire da 1. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | stringa (obbligatorio) |
| inputs | Elenco di campi per il filtro nell'espressione di percorso JSON. | string[] (obbligatorio) |
| type | Tipo di operazione del flusso di dati. | 'Filter' |
DataflowBuiltInTransformationMap
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa della funzione di mapping. | string Constraints: Lunghezza massima = 256 |
| expression | Modificare i campi di input nel campo di output finale. Esempio: $1 * 2,2 (presupponendo che venga fornita la sezione $1) | string |
| inputs | Elenco di campi per il mapping nell'espressione di percorso JSON. | string[] (obbligatorio) |
| output | Dove e come organizzare i campi di input nel record di output. | stringa (obbligatorio) |
| type | Tipo di trasformazione. | 'BuiltInFunction' 'Compute' 'NewProperties' 'PassThrough' 'Rename' |
DataflowBuiltInTransformationSettings
| Name | Description | Value |
|---|---|---|
| datasets | Arricchire i dati dall'archivio stati broker. Il set di dati fa riferimento a una chiave nell'archivio stati di Broker. | DataflowBuiltInTransformationDataset[] |
| filter | Filtra i record di input o i punti dati in base alla condizione. | DataflowBuiltInTransformationFilter[] |
| map | Esegue il mapping dell'input al messaggio di output. | DataflowBuiltInTransformationMap[] |
| schemaRef | Riferimento allo schema che descrive l'output della trasformazione. | string |
| serializationFormat | Formato di serializzazione. Opzionale; il valore predefinito è JSON. Valore consentito JSON Schema/draft-7, Parquet. Impostazione predefinita: Json | 'Delta' 'Json' 'Parquet' |
DataflowDestinationAddIfNotPresentHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddIfNotPresent' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere. | stringa (obbligatorio) |
DataflowDestinationAddOrReplaceHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddOrReplace' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
DataflowDestinationHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Impostare su 'AddIfNotPresent' per il tipo DataflowDestinationAddIfNotPresentHeaderAction. Impostare su 'AddOrReplace' per il tipo DataflowDestinationAddOrReplaceHeaderAction. Impostare su 'Rimuovi' per il tipo DataflowDestinationRemoveHeaderAction. | 'AddIfNotPresent' 'AggiungiOrSostituisci' 'Rimuovi' (obbligatorio) |
DataflowDestinationOperationSettings
| Name | Description | Value |
|---|---|---|
| dataDestination | Il percorso di destinazione può essere un argomento o un nome di tabella. Supporta valori dinamici con $topic, $systemProperties, $userProperties, $payload, $context e $subscription. | string Constraints: Lunghezza minima = 1 (obbligatorio) |
| endpointRef | Riferimento all'endpoint CR. Può essere di tipo Broker, Kafka, Fabric, ADLS, ADX. | stringa (obbligatorio) |
| headers | Intestazioni per i dati di output. | DataflowDestinationHeaderAction[] |
DataflowDestinationRemoveHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'Rimuovi' (obbligatorio) |
| key | Nome dell'intestazione da rimuovere. | stringa (obbligatorio) |
DataflowOperation
| Name | Description | Value |
|---|---|---|
| builtInTransformationSettings | Configurazione della trasformazione predefinita. | DataflowBuiltInTransformationSettings |
| destinationSettings | Configurazione della destinazione. | DataflowDestinationOperationSettings |
| name | Nome facoltativo fornito dall'utente della trasformazione. | string Constraints: Lunghezza massima = 64 |
| operationType | Tipo di operazione. | 'BuiltInTransformation' 'Destination' 'Fonte' (obbligatorio) |
| sourceSettings | Configurazione dell'origine. | DataflowSourceOperationSettings |
DataflowProperties
| Name | Description | Value |
|---|---|---|
| mode | Modalità per flusso di dati. Opzionale; il valore predefinito è Abilitato. | 'Disabled' 'Enabled' |
| operations | Elenco di operazioni, inclusi i riferimenti all'origine e alla destinazione, nonché la trasformazione. | DataflowOperation[] (obbligatorio) |
| requestDiskPersistence | Modalità di persistenza del disco. | 'Disabled' 'Enabled' |
DataflowSourceOperationSettings
| Name | Description | Value |
|---|---|---|
| assetRef | Riferimento alla risorsa in Registro dispositivi di Azure da cui provengono i dati nell'endpoint. | string |
| dataSources | Elenco delle posizioni di origine. Può essere broker o argomenti Kafka. Supporta i caratteri jolly # e +. | string Constraints: Lunghezza minima = 1[] (obbligatorio) |
| endpointRef | Riferimento alla risorsa endpoint flusso di dati. Può essere solo di tipo Broker e Kafka. | stringa (obbligatorio) |
| schemaRef | Riferimento cr dello schema. I dati verranno deserializzati in base allo schema e eliminati se non corrispondono. | string |
| serializationFormat | Il contenuto è uno schema JSON. Consentito: schema JSON/bozza-7. | 'Json' |
ExtendedLocation
| Name | Description | Value |
|---|---|---|
| name | Nome della posizione estesa. | stringa (obbligatorio) |
| type | Tipo di ExtendedLocation. | 'CustomLocation' (obbligatorio) |
Definizione di risorsa Terraform (provider AzAPI)
Il tipo di risorsa instances/dataflowProfiles/dataflows può essere distribuito con operazioni destinate a:
- Gruppi di risorse Per un elenco delle proprietà modificate in ogni versione dell'API, vedi il registro modifiche.
Formato risorsa
Per creare una risorsa Microsoft.IoTOperations/instances/dataflowProfiles/dataflows, aggiungere il codice Terraform seguente al modello.
resource "azapi_resource" "symbolicname" {
type = "Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2026-07-01"
name = "string"
parent_id = "string"
body = {
extendedLocation = {
name = "string"
type = "string"
}
properties = {
mode = "string"
operations = [
{
builtInTransformationSettings = {
datasets = [
{
description = "string"
expression = "string"
inputs = [
"string"
]
key = "string"
schemaRef = "string"
}
]
filter = [
{
description = "string"
expression = "string"
inputs = [
"string"
]
type = "string"
}
]
map = [
{
description = "string"
expression = "string"
inputs = [
"string"
]
output = "string"
type = "string"
}
]
schemaRef = "string"
serializationFormat = "string"
}
destinationSettings = {
dataDestination = "string"
endpointRef = "string"
headers = [
{
actionType = "string"
// For remaining properties, see DataflowDestinationHeaderAction objects
}
]
}
name = "string"
operationType = "string"
sourceSettings = {
assetRef = "string"
dataSources = [
"string"
]
endpointRef = "string"
schemaRef = "string"
serializationFormat = "string"
}
}
]
requestDiskPersistence = "string"
}
}
}
Oggetti DataflowDestinationHeaderAction
Impostare la proprietà actionType per specificare il tipo di oggetto.
Per AddIfNotPresent, utilizzare:
{
actionType = "AddIfNotPresent"
key = "string"
value = "string"
}
Per AddOrReplace, utilizzare:
{
actionType = "AddOrReplace"
key = "string"
value = "string"
}
Per Rimuovere, utilizzare:
{
actionType = "Remove"
key = "string"
}
Valori delle proprietà
Microsoft.IoTOperations/instances/dataflowProfiles/dataflows
| Name | Description | Value |
|---|---|---|
| extendedLocation | Posizione perimetrale della risorsa. | ExtendedLocation |
| name | Nome della risorsa | string Constraints: Lunghezza minima = 3 Lunghezza massima = 63 Pattern = ^[a-z0-9][a-z0-9-]*[a-z0-9]$ (obbligatorio) |
| parent_id | ID della risorsa padre per questa risorsa. | ID per la risorsa di tipo: instances/dataflowProfiles |
| properties | Proprietà specifiche della risorsa. | DataflowProperties |
| type | Tipo di risorsa | "Microsoft. IoTOperations/instances/dataflowProfiles/dataflows@2026-07-01" |
DataflowBuiltInTransformationDataset
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del set di dati. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per arricchire i dati dall'archivio stati broker. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | string |
| inputs | Elenco di campi per l'arricchimento da Archivio stati broker. | string[] (obbligatorio) |
| key | Chiave del set di dati. | string Constraints: Lunghezza massima = 64 (obbligatorio) |
| schemaRef | Riferimento allo schema che descrive il set di dati. Consentito: schema JSON/bozza-7. | string |
DataflowBuiltInTransformationFilter
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa del filtro. | string Constraints: Lunghezza massima = 256 |
| expression | Condizione per filtrare i dati. Può fare riferimento ai campi di input con {n} dove n è l'indice del campo di input a partire da 1. Esempio: $1 < 0 || $1 > $2 (supponendo che vengano forniti input sezione $1 e $2) | stringa (obbligatorio) |
| inputs | Elenco di campi per il filtro nell'espressione di percorso JSON. | string[] (obbligatorio) |
| type | Tipo di operazione del flusso di dati. | 'Filter' |
DataflowBuiltInTransformationMap
| Name | Description | Value |
|---|---|---|
| description | Un utente ha fornito una descrizione facoltativa della funzione di mapping. | string Constraints: Lunghezza massima = 256 |
| expression | Modificare i campi di input nel campo di output finale. Esempio: $1 * 2,2 (presupponendo che venga fornita la sezione $1) | string |
| inputs | Elenco di campi per il mapping nell'espressione di percorso JSON. | string[] (obbligatorio) |
| output | Dove e come organizzare i campi di input nel record di output. | stringa (obbligatorio) |
| type | Tipo di trasformazione. | 'BuiltInFunction' 'Compute' 'NewProperties' 'PassThrough' 'Rename' |
DataflowBuiltInTransformationSettings
| Name | Description | Value |
|---|---|---|
| datasets | Arricchire i dati dall'archivio stati broker. Il set di dati fa riferimento a una chiave nell'archivio stati di Broker. | DataflowBuiltInTransformationDataset[] |
| filter | Filtra i record di input o i punti dati in base alla condizione. | DataflowBuiltInTransformationFilter[] |
| map | Esegue il mapping dell'input al messaggio di output. | DataflowBuiltInTransformationMap[] |
| schemaRef | Riferimento allo schema che descrive l'output della trasformazione. | string |
| serializationFormat | Formato di serializzazione. Opzionale; il valore predefinito è JSON. Valore consentito JSON Schema/draft-7, Parquet. Impostazione predefinita: Json | 'Delta' 'Json' 'Parquet' |
DataflowDestinationAddIfNotPresentHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddIfNotPresent' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere. | stringa (obbligatorio) |
DataflowDestinationAddOrReplaceHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'AddOrReplace' (obbligatorio) |
| key | Nome dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
| value | Valore dell'intestazione da aggiungere o sostituire. | stringa (obbligatorio) |
DataflowDestinationHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Impostare su 'AddIfNotPresent' per il tipo DataflowDestinationAddIfNotPresentHeaderAction. Impostare su 'AddOrReplace' per il tipo DataflowDestinationAddOrReplaceHeaderAction. Impostare su 'Rimuovi' per il tipo DataflowDestinationRemoveHeaderAction. | 'AddIfNotPresent' 'AggiungiOrSostituisci' 'Rimuovi' (obbligatorio) |
DataflowDestinationOperationSettings
| Name | Description | Value |
|---|---|---|
| dataDestination | Il percorso di destinazione può essere un argomento o un nome di tabella. Supporta valori dinamici con $topic, $systemProperties, $userProperties, $payload, $context e $subscription. | string Constraints: Lunghezza minima = 1 (obbligatorio) |
| endpointRef | Riferimento all'endpoint CR. Può essere di tipo Broker, Kafka, Fabric, ADLS, ADX. | stringa (obbligatorio) |
| headers | Intestazioni per i dati di output. | DataflowDestinationHeaderAction[] |
DataflowDestinationRemoveHeaderAction
| Name | Description | Value |
|---|---|---|
| actionType | Tipo di operazione di intestazione da eseguire. | 'Rimuovi' (obbligatorio) |
| key | Nome dell'intestazione da rimuovere. | stringa (obbligatorio) |
DataflowOperation
| Name | Description | Value |
|---|---|---|
| builtInTransformationSettings | Configurazione della trasformazione predefinita. | DataflowBuiltInTransformationSettings |
| destinationSettings | Configurazione della destinazione. | DataflowDestinationOperationSettings |
| name | Nome facoltativo fornito dall'utente della trasformazione. | string Constraints: Lunghezza massima = 64 |
| operationType | Tipo di operazione. | 'BuiltInTransformation' 'Destination' 'Fonte' (obbligatorio) |
| sourceSettings | Configurazione dell'origine. | DataflowSourceOperationSettings |
DataflowProperties
| Name | Description | Value |
|---|---|---|
| mode | Modalità per flusso di dati. Opzionale; il valore predefinito è Abilitato. | 'Disabled' 'Enabled' |
| operations | Elenco di operazioni, inclusi i riferimenti all'origine e alla destinazione, nonché la trasformazione. | DataflowOperation[] (obbligatorio) |
| requestDiskPersistence | Modalità di persistenza del disco. | 'Disabled' 'Enabled' |
DataflowSourceOperationSettings
| Name | Description | Value |
|---|---|---|
| assetRef | Riferimento alla risorsa in Registro dispositivi di Azure da cui provengono i dati nell'endpoint. | string |
| dataSources | Elenco delle posizioni di origine. Può essere broker o argomenti Kafka. Supporta i caratteri jolly # e +. | string Constraints: Lunghezza minima = 1[] (obbligatorio) |
| endpointRef | Riferimento alla risorsa endpoint flusso di dati. Può essere solo di tipo Broker e Kafka. | stringa (obbligatorio) |
| schemaRef | Riferimento cr dello schema. I dati verranno deserializzati in base allo schema e eliminati se non corrispondono. | string |
| serializationFormat | Il contenuto è uno schema JSON. Consentito: schema JSON/bozza-7. | 'Json' |
ExtendedLocation
| Name | Description | Value |
|---|---|---|
| name | Nome della posizione estesa. | stringa (obbligatorio) |
| type | Tipo di ExtendedLocation. | 'CustomLocation' (obbligatorio) |