There are not good samples available for JSON files to create Stream Analytics Jobs. Here are sample which can form input to PowerShell cmdlet.
New-AzureStreamAnalyticsJob -ResourceGroupName <Any name> -File <Json file name> -Name <Stream Analytics Job Name>
Here is the Json file that can write to Blob storage.
{
"location":"Central US",
"properties":{
"sku":{
"name":"standard"
},
"eventsOutOfOrderPolicy":"drop",
"eventsOutOfOrderMaxDelayInSeconds":10,
"inputs":[
{
"name":"input",
"properties":{
"type":"stream",
"serialization":{
"type":"JSON",
"properties":{
"encoding":"UTF8"
}
},
"datasource":{
"type":"Microsoft.ServiceBus/EventHub",
"properties":{
"eventHubNamespace":"",
"sharedAccessPolicyName":"manage",
"sharedAccessPolicyKey":"",
"serviceBusNamespace":"",
"eventHubName":""
}
}
}
}
],
"transformation":{
"name":"ProcessSampleData",
"properties":{
"streamingUnits":1,
"query":"select * from input"
}
},
"outputs":[
{
"name":"outputblob",
"properties":{
"datasource":{
"type":"Microsoft.Storage/Blob",
"properties":{
"storageAccounts":[{
"accountName":"",
"accountKey":""
}],
"container":"rawoutputcontainer",
"blobPathPrefix":"md"
}
},
"serialization":{
"type":"CSV",
"properties":{
"fieldDelimiter":",",
"encoding":"UTF8"
}
}
}
}
]
}
}
New-AzureStreamAnalyticsJob -ResourceGroupName <Any name> -File <Json file name> -Name <Stream Analytics Job Name>
Here is the Json file that can write to Blob storage.
{
"location":"Central US",
"properties":{
"sku":{
"name":"standard"
},
"eventsOutOfOrderPolicy":"drop",
"eventsOutOfOrderMaxDelayInSeconds":10,
"inputs":[
{
"name":"input",
"properties":{
"type":"stream",
"serialization":{
"type":"JSON",
"properties":{
"encoding":"UTF8"
}
},
"datasource":{
"type":"Microsoft.ServiceBus/EventHub",
"properties":{
"eventHubNamespace":"",
"sharedAccessPolicyName":"manage",
"sharedAccessPolicyKey":"",
"serviceBusNamespace":"",
"eventHubName":""
}
}
}
}
],
"transformation":{
"name":"ProcessSampleData",
"properties":{
"streamingUnits":1,
"query":"select * from input"
}
},
"outputs":[
{
"name":"outputblob",
"properties":{
"datasource":{
"type":"Microsoft.Storage/Blob",
"properties":{
"storageAccounts":[{
"accountName":"",
"accountKey":""
}],
"container":"rawoutputcontainer",
"blobPathPrefix":"md"
}
},
"serialization":{
"type":"CSV",
"properties":{
"fieldDelimiter":",",
"encoding":"UTF8"
}
}
}
}
]
}
}
ReplyDeleteBrilliant blog I visit this blog it's incredibly awesome. Curiously, in this blog content formed doubtlessly and sensible. The substance of information is helpful.
Oracle Fusion HCM Online Training
Oracle Fusion SCM Online Training
Oracle Fusion Financials Online Training
Oracle Fusion HCM Training In Hyderabad
Oracle Fusion SCM Training In Hyderabad
Oracle Fusion Financials Training In Hyderabad
oracle fusion financials classroom training
Oracle Fusion HCM Classroom Training
oracle cpq online training / Oracle CPQ Class Room Training
Oracle Taleo Online Training
Python training in bangalore
ReplyDeleteMachine learning course in bangalore
Data Science Online Course in Bangalore
Learn Storage Automation (Using Python) in Bangalore BTM
Cloud Computing Training in Bangalore BTM