dataflows

Creates, updates, deletes, gets or lists a dataflows resource.

Overview

Name	dataflows
Type	Resource
Id	azure.iotoperations.dataflows

Fields

vw_dataflows

Name	Datatype	Description
dataflowName	text	field from the properties object
dataflowProfileName	text	field from the properties object
extended_location	text	field from the properties object
instanceName	text	field from the properties object
mode	text	field from the properties object
operations	text	field from the properties object
provisioning_state	text	field from the properties object
resourceGroupName	text	field from the properties object
subscriptionId	text	field from the properties object

dataflows

Name	Datatype	Description
extendedLocation	object	Extended location is an extension of Azure locations. They provide a way to use their Azure ARC enabled Kubernetes clusters as target locations for deploying Azure services instances.
properties	object	Dataflow Resource properties

Methods

Name	Accessible by	Required Params	Description
get	SELECT	dataflowName, dataflowProfileName, instanceName, resourceGroupName, subscriptionId	Get a DataflowResource
list_by_profile_resource	SELECT	dataflowProfileName, instanceName, resourceGroupName, subscriptionId	List DataflowResource resources by DataflowProfileResource
create_or_update	INSERT	dataflowName, dataflowProfileName, instanceName, resourceGroupName, subscriptionId, data__extendedLocation	Create a DataflowResource
delete	DELETE	dataflowName, dataflowProfileName, instanceName, resourceGroupName, subscriptionId	Delete a DataflowResource

SELECT examples

List DataflowResource resources by DataflowProfileResource

vw_dataflows

SELECT
dataflowName,
dataflowProfileName,
extended_location,
instanceName,
mode,
operations,
provisioning_state,
resourceGroupName,
subscriptionId
FROM azure.iotoperations.vw_dataflows
WHERE dataflowProfileName = '{{ dataflowProfileName }}'
AND instanceName = '{{ instanceName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';

dataflows

SELECT
extendedLocation,
properties
FROM azure.iotoperations.dataflows
WHERE dataflowProfileName = '{{ dataflowProfileName }}'
AND instanceName = '{{ instanceName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';

INSERT example

Use the following StackQL query and manifest file to create a new dataflows resource.

All Properties

/*+ create */
INSERT INTO azure.iotoperations.dataflows (
dataflowName,
dataflowProfileName,
instanceName,
resourceGroupName,
subscriptionId,
data__extendedLocation,
properties,
extendedLocation
)
SELECT 
'{{ dataflowName }}',
'{{ dataflowProfileName }}',
'{{ instanceName }}',
'{{ resourceGroupName }}',
'{{ subscriptionId }}',
'{{ data__extendedLocation }}',
'{{ properties }}',
'{{ extendedLocation }}'
;

Manifest

- name: your_resource_model_name
  props:
    - name: properties
      value:
        - name: mode
          value: string
        - name: operations
          value:
            - - name: operationType
                value: []
              - name: name
                value: string
              - name: sourceSettings
                value:
                  - name: endpointRef
                    value: string
                  - name: assetRef
                    value: string
                  - name: serializationFormat
                    value: string
                  - name: schemaRef
                    value: string
                  - name: dataSources
                    value:
                      - string
              - name: builtInTransformationSettings
                value:
                  - name: serializationFormat
                    value: string
                  - name: schemaRef
                    value: string
                  - name: datasets
                    value:
                      - - name: key
                          value: string
                        - name: description
                          value: string
                        - name: schemaRef
                          value: string
                        - name: inputs
                          value:
                            - string
                        - name: expression
                          value: string
                  - name: filter
                    value:
                      - - name: type
                          value: string
                        - name: description
                          value: string
                        - name: inputs
                          value:
                            - string
                        - name: expression
                          value: string
                  - name: map
                    value:
                      - - name: type
                          value: []
                        - name: description
                          value: string
                        - name: inputs
                          value:
                            - string
                        - name: expression
                          value: string
                        - name: output
                          value: string
              - name: destinationSettings
                value:
                  - name: endpointRef
                    value: string
                  - name: dataDestination
                    value: string
        - name: provisioningState
          value: []
    - name: extendedLocation
      value:
        - name: name
          value: string
        - name: type
          value: []

DELETE example

Deletes the specified dataflows resource.

/*+ delete */
DELETE FROM azure.iotoperations.dataflows
WHERE dataflowName = '{{ dataflowName }}'
AND dataflowProfileName = '{{ dataflowProfileName }}'
AND instanceName = '{{ instanceName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';