attributes

azure_stream_analytics/attribute_ingestion/Inputs/hotattribute.json

@@ -0,0 +1,21 @@
+{
+    "Name": "hotattribute",
+    "Type": "Data Stream",
+    "DataSourceType": "Event Hub",
+    "EventHubProperties": {
+        "ServiceBusNamespace": "ehns001",
+        "EventHubName": "endpoint_attributes",
+        "SharedAccessPolicyName": "attribute_ingestion_hotattribute_policy",
+        "SharedAccessPolicyKey": null,
+        "ConsumerGroupName": "attribute_ingestion_hotattribute_consumer_group",
+        "AuthenticationMode": "ConnectionString"
+    },
+    "DataSourceCredentialDomain": "9b18630a-f8b4-40c4-936f-93664ba728de.StreamAnalystics",
+    "Serialization": {
+        "Type": "Json",
+        "Encoding": "UTF8"
+    },
+    "PartitionKey": "",
+    "CompressionType": "None",
+    "ScriptType": "Input"
+}

azure_stream_analytics/attribute_ingestion/JobConfig.json

@@ -0,0 +1,29 @@
+{
+    "ScriptType": "JobConfig",
+    "DataLocale": "en-US",
+    "OutputErrorPolicy": "Retry",
+    "EventsLateArrivalMaxDelayInSeconds": 5,
+    "EventsOutOfOrderMaxDelayInSeconds": 0,
+    "EventsOutOfOrderPolicy": "Adjust",
+    "StreamingUnits": 3,
+    "CompatibilityLevel": "1.2",
+    "UseSystemAssignedIdentity": false,
+    "GlobalStorage": {
+        "AccountName": null,
+        "AccountKey": null,
+        "AuthenticationMode": "ConnectionString"
+    },
+    "ContentStoragePolicy": "SystemAccount",
+    "CustomCodeStorage": {
+        "AccountName": null,
+        "AccountKey": null,
+        "ContainerName": null,
+        "Path": null
+    },
+    "VirtualNetworkConfiguration": {
+        "VirtualNetworkName": null,
+        "SubnetResourceId": null
+    },
+    "DataSourceCredentialDomain": null,
+    "Tags": {}
+}

azure_stream_analytics/attribute_ingestion/Outputs/sqltable.json

@@ -0,0 +1,16 @@
+{
+    "Name": "sqltable",
+    "DataSourceType": "SQL Database",
+    "SQLDatabaseProperties": {
+        "Database": "db01",
+        "Server": "msqldemo",
+        "User": "jamesn",
+        "Password": null,
+        "Table": "endpoint_conf_change",
+        "MaxWriterCount": 1,
+        "MaxBatchCount": 10000,
+        "AuthenticationMode": "ConnectionString"
+    },
+    "DataSourceCredentialDomain": null,
+    "ScriptType": "Output"
+}

azure_stream_analytics/attribute_ingestion/Transformation.asaql

@@ -0,0 +1,6 @@
+SELECT
+     ep_id, eventtime, attr as attr_name, attr_val as attr_value
+INTO
+    [sqltable]
+FROM
+    [hotattribute]

azure_stream_analytics/attribute_ingestion/asaproj.json

@@ -0,0 +1,18 @@
+{
+    "name": "attribute_ingestion",
+    "startFile": "Transformation.asaql",
+    "configurations": [
+        {
+            "filePath": "JobConfig.json",
+            "subType": "JobConfig"
+        },
+        {
+            "filePath": "Outputs/sqltable.json",
+            "subType": "Output"
+        },
+        {
+            "filePath": "Inputs/hotattribute.json",
+            "subType": "Input"
+        }
+    ]
+}