transformations

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

Overview

Name	transformations
Type	Resource
Id	azure.stream_analytics.transformations

Fields

vw_transformations

Name	Datatype	Description
id	text	Resource Id
name	text	Resource name
etag	text	field from the properties object
jobName	text	field from the properties object
query	text	field from the properties object
resourceGroupName	text	field from the properties object
streaming_units	text	field from the properties object
subscriptionId	text	field from the properties object
transformationName	text	field from the properties object
type	text	Resource type
valid_streaming_units	text	field from the properties object

transformations

Name	Datatype	Description
id	string	Resource Id
name	string	Resource name
properties	object	The properties that are associated with a transformation.
type	string	Resource type

Methods

Name	Accessible by	Required Params	Description
get	SELECT	jobName, resourceGroupName, subscriptionId, transformationName	Gets details about the specified transformation.
create_or_replace	INSERT	jobName, resourceGroupName, subscriptionId, transformationName	Creates a transformation or replaces an already existing transformation under an existing streaming job.
update	UPDATE	jobName, resourceGroupName, subscriptionId, transformationName	Updates an existing transformation under an existing streaming job. This can be used to partially update (ie. update one or two properties) a transformation without affecting the rest the job or transformation definition.

SELECT examples

Gets details about the specified transformation.

vw_transformations

SELECT
id,
name,
etag,
jobName,
query,
resourceGroupName,
streaming_units,
subscriptionId,
transformationName,
type,
valid_streaming_units
FROM azure.stream_analytics.vw_transformations
WHERE jobName = '{{ jobName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}'
AND transformationName = '{{ transformationName }}';

transformations

SELECT
id,
name,
properties,
type
FROM azure.stream_analytics.transformations
WHERE jobName = '{{ jobName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}'
AND transformationName = '{{ transformationName }}';

INSERT example

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

All Properties

/*+ create */
INSERT INTO azure.stream_analytics.transformations (
jobName,
resourceGroupName,
subscriptionId,
transformationName,
name,
properties
)
SELECT 
'{{ jobName }}',
'{{ resourceGroupName }}',
'{{ subscriptionId }}',
'{{ transformationName }}',
'{{ name }}',
'{{ properties }}'
;

Manifest

- name: your_resource_model_name
  props:
    - name: id
      value: string
    - name: name
      value: string
    - name: type
      value: string
    - name: properties
      value:
        - name: streamingUnits
          value: integer
        - name: validStreamingUnits
          value:
            - integer
        - name: query
          value: string
        - name: etag
          value: string

UPDATE example

Updates a transformations resource.

/*+ update */
UPDATE azure.stream_analytics.transformations
SET 
name = '{{ name }}',
properties = '{{ properties }}'
WHERE 
jobName = '{{ jobName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}'
AND transformationName = '{{ transformationName }}';