inputs

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

Overview

Name	inputs
Type	Resource
Id	azure.stream_analytics.inputs

Fields

vw_inputs

Name	Datatype	Description
id	text	Resource Id
name	text	Resource name
compression	text	field from the properties object
diagnostics	text	field from the properties object
etag	text	field from the properties object
inputName	text	field from the properties object
jobName	text	field from the properties object
partition_key	text	field from the properties object
resourceGroupName	text	field from the properties object
serialization	text	field from the properties object
subscriptionId	text	field from the properties object
type	text	Resource type

inputs

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

Methods

Name	Accessible by	Required Params	Description
get	SELECT	inputName, jobName, resourceGroupName, subscriptionId	Gets details about the specified input.
list_by_streaming_job	SELECT	jobName, resourceGroupName, subscriptionId	Lists all of the inputs under the specified streaming job.
create_or_replace	INSERT	inputName, jobName, resourceGroupName, subscriptionId	Creates an input or replaces an already existing input under an existing streaming job.
delete	DELETE	inputName, jobName, resourceGroupName, subscriptionId	Deletes an input from the streaming job.
update	UPDATE	inputName, jobName, resourceGroupName, subscriptionId	Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
test	EXEC	inputName, jobName, resourceGroupName, subscriptionId	Tests whether an input’s datasource is reachable and usable by the Azure Stream Analytics service.

SELECT examples

Lists all of the inputs under the specified streaming job.

vw_inputs

SELECT
id,
name,
compression,
diagnostics,
etag,
inputName,
jobName,
partition_key,
resourceGroupName,
serialization,
subscriptionId,
type
FROM azure.stream_analytics.vw_inputs
WHERE jobName = '{{ jobName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';

inputs

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

INSERT example

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

All Properties

/*+ create */
INSERT INTO azure.stream_analytics.inputs (
inputName,
jobName,
resourceGroupName,
subscriptionId,
name,
properties
)
SELECT 
'{{ inputName }}',
'{{ jobName }}',
'{{ resourceGroupName }}',
'{{ subscriptionId }}',
'{{ 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: type
          value: string
        - name: serialization
          value:
            - name: type
              value: []
        - name: diagnostics
          value:
            - name: conditions
              value:
                - - name: since
                    value: string
                  - name: code
                    value: string
                  - name: message
                    value: string
        - name: etag
          value: string
        - name: compression
          value:
            - name: type
              value: []
        - name: partitionKey
          value: string

UPDATE example

Updates a inputs resource.

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

DELETE example

Deletes the specified inputs resource.

/*+ delete */
DELETE FROM azure.stream_analytics.inputs
WHERE inputName = '{{ inputName }}'
AND jobName = '{{ jobName }}'
AND resourceGroupName = '{{ resourceGroupName }}'
AND subscriptionId = '{{ subscriptionId }}';