data_flows

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

Overview

Name	data_flows
Type	Resource
Id	azure.data_factory.data_flows

Fields

vw_data_flows

Name	Datatype	Description
id	text	The resource identifier.
name	text	The resource name.
description	text	field from the properties object
annotations	text	field from the properties object
dataFlowName	text	field from the properties object
etag	text	Etag identifies change in the resource.
factoryName	text	field from the properties object
folder	text	field from the properties object
resourceGroupName	text	field from the properties object
subscriptionId	text	field from the properties object
type	text	The resource type.

data_flows

Name	Datatype	Description
id	string	The resource identifier.
name	string	The resource name.
etag	string	Etag identifies change in the resource.
properties	object	Azure Data Factory nested object which contains a flow with data movements and transformations.
type	string	The resource type.

Methods

Name	Accessible by	Required Params	Description
get	SELECT	dataFlowName, factoryName, resourceGroupName, subscriptionId	Gets a data flow.
list_by_factory	SELECT	factoryName, resourceGroupName, subscriptionId	Lists data flows.
create_or_update	INSERT	dataFlowName, factoryName, resourceGroupName, subscriptionId, data__properties	Creates or updates a data flow.
delete	DELETE	dataFlowName, factoryName, resourceGroupName, subscriptionId	Deletes a data flow.

SELECT examples

Lists data flows.

vw_data_flows

SELECT
id,
name,
description,
annotations,
dataFlowName,
etag,
factoryName,
folder,
resourceGroupName,
subscriptionId,
type
FROM azure.data_factory.vw_data_flows
WHERE factoryName = '{{ factoryName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';

data_flows

SELECT
id,
name,
etag,
properties,
type
FROM azure.data_factory.data_flows
WHERE factoryName = '{{ factoryName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';

INSERT example

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

All Properties

/*+ create */
INSERT INTO azure.data_factory.data_flows (
dataFlowName,
factoryName,
resourceGroupName,
subscriptionId,
data__properties,
properties
)
SELECT 
'{{ dataFlowName }}',
'{{ factoryName }}',
'{{ resourceGroupName }}',
'{{ subscriptionId }}',
'{{ data__properties }}',
'{{ properties }}'
;

Manifest

- name: your_resource_model_name
  props:
    - name: id
      value: string
    - name: name
      value: string
    - name: type
      value: string
    - name: etag
      value: string
    - name: properties
      value:
        - name: type
          value: string
        - name: description
          value: string
        - name: annotations
          value:
            - object
        - name: folder
          value:
            - name: name
              value: string

DELETE example

Deletes the specified data_flows resource.

/*+ delete */
DELETE FROM azure.data_factory.data_flows
WHERE dataFlowName = '{{ dataFlowName }}'
AND factoryName = '{{ factoryName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';