Streaming Jobs - List

Mencantumkan semua pekerjaan streaming dalam langganan tertentu.

GET https://management.azure.com/subscriptions/{subscriptionId}/providers/Microsoft.StreamAnalytics/streamingjobs?api-version=2017-04-01-preview
GET https://management.azure.com/subscriptions/{subscriptionId}/providers/Microsoft.StreamAnalytics/streamingjobs?$expand={$expand}&api-version=2017-04-01-preview

Parameter URI

Name In Required Type Description
subscriptionId
path True
  • string

ID langganan target.

api-version
query True
  • string

Versi API yang digunakan untuk operasi ini.

$expand
query
  • string

Parameter kueri $expand OData. Ini adalah daftar properti pekerjaan streaming tambahan yang dipisahkan koma untuk disertakan dalam respons, di luar set default yang dikembalikan ketika parameter ini tidak ada. Set default adalah semua properti pekerjaan streaming selain 'input', 'transformasi', 'output', dan 'fungsi'.

Respons

Name Type Description
200 OK

Berhasil mencantumkan pekerjaan streaming di bawah langganan yang diberikan.

Other Status Codes

Kesalahan.

Keamanan

azure_auth

Azure Active Directory Flow OAuth2

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name Description
user_impersonation meniru akun pengguna Anda

Contoh

List all streaming jobs in a subscription and do not use the $expand OData query parameter
List all streaming jobs in a subscription and use the $expand OData query parameter to expand inputs, outputs, transformation, and functions

List all streaming jobs in a subscription and do not use the $expand OData query parameter

Sample Request

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/providers/Microsoft.StreamAnalytics/streamingjobs?api-version=2017-04-01-preview

Sample Response

{
  "value": [
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest",
      "name": "asaClusterTest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "hidden-link:/Microsoft.StreamAnalytics/streamingjobs/inputs/input": "{\"partitionCount\":2}"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "c5b86804-4b8e-4d99-885f-910ea24b51f4",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-15T03:41:25.7Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": null,
        "contentStoragePolicy": "SystemAccount",
        "etag": "ba6f6d8e-57e2-45bd-87ba-2b62c259bbcc",
        "jobType": "Cloud",
        "cluster": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/clusters/zhejunASA"
        }
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest",
      "name": "ASAUDFTest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {},
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "8b39d20f-d8df-42e0-8198-a20160e4696b",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-16T05:56:55.51Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": {
          "authenticationMode": "ConnectionString",
          "accountName": "zhejuntest"
        },
        "contentStoragePolicy": "SystemAccount",
        "etag": "bfee3a7f-cdaf-4b1e-b449-71a3b8b4d6d9",
        "jobType": "Edge",
        "externals": {
          "storageAccount": {
            "accountName": "zhejuntest"
          },
          "container": "container2",
          "path": "UserCustomCode.zip"
        },
        "cluster": null
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest",
      "name": "zhejunmltest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "aacee415-41d4-47f6-acf4-de9ae50175b0",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Drop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-17T08:36:07.463Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": null,
        "contentStoragePolicy": "SystemAccount",
        "etag": "89ba3a42-e217-432e-bf23-798dbf001519",
        "jobType": "Cloud",
        "cluster": null
      }
    }
  ],
  "nextLink": null
}

List all streaming jobs in a subscription and use the $expand OData query parameter to expand inputs, outputs, transformation, and functions

Sample Request

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/providers/Microsoft.StreamAnalytics/streamingjobs?$expand=inputs,outputs,transformation,functions&api-version=2017-04-01-preview

Sample Response

{
  "value": [
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest",
      "name": "asaClusterTest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "hidden-link:/Microsoft.StreamAnalytics/streamingjobs/inputs/input": "{\"partitionCount\":2}"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "c5b86804-4b8e-4d99-885f-910ea24b51f4",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-15T03:41:25.7Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": null,
        "contentStoragePolicy": "SystemAccount",
        "inputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest/inputs/HistoricalTrafficData",
            "name": "HistoricalTrafficData",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Reference",
              "datasource": {
                "type": "Microsoft.Storage/Blob",
                "properties": {
                  "storageAccounts": [
                    {
                      "accountName": "zhejuntest"
                    }
                  ],
                  "container": "container1",
                  "pathPattern": "{date}{time}",
                  "dateFormat": "yyyy/MM/dd",
                  "timeFormat": "HH"
                }
              },
              "compression": {
                "type": "None"
              },
              "serialization": {
                "type": "Csv",
                "properties": {
                  "fieldDelimiter": ",",
                  "encoding": "UTF8"
                }
              },
              "etag": "8ffd285f-cc45-4a0a-9e0b-a7cfd7f7130c"
            }
          },
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest/inputs/input",
            "name": "input",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Stream",
              "datasource": {
                "type": "Microsoft.ServiceBus/EventHub",
                "properties": {
                  "consumerGroupName": "1",
                  "eventHubName": "input",
                  "serviceBusNamespace": "azuremlbugbash",
                  "sharedAccessPolicyName": "inputpolicy",
                  "authenticationMode": "ConnectionString"
                }
              },
              "compression": {
                "type": "None"
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8"
                }
              },
              "etag": "d62c06ad-343b-4631-81cc-2c63c4081869"
            }
          }
        ],
        "transformation": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest/transformations/Transformation",
          "name": "Transformation",
          "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
          "properties": {
            "streamingUnits": 3,
            "query": "-- input refers to the alias of your event hub \r\n\r\nWITH  \r\n\r\nTripData AS ( \r\n\r\n    SELECT TRY_CAST(pickupLat AS float) as pickupLat, \r\n\r\n    TRY_CAST(pickupLon AS float) as pickupLon, \r\n\r\n    passengerCount, TripTimeinSeconds,  \r\n\r\n    pickupTime, VendorID, tripDistanceInMiles \r\n\r\n    FROM input timestamp by pickupTime \r\n\r\n    WHERE pickupLat > -90 AND pickupLat < 90 AND pickupLon > -180 AND pickupLon < 180 \r\n\r\n) \r\n\r\n \r\n\r\n--query 1 \r\n\r\nSELECT count(*), system.timestamp as timestamps \r\n\r\nINTO output \r\n\r\nFROM TripData \r\n\r\nGroup by hoppingwindow(second,60,5) \r\n\r\n \r\n\r\n \r\n\r\n--query 2 where HistoricalTrafficData is the alias of your reference data \r\n\r\nSELECT count(TripData.VendorID) as NbTrips, avg(TripData.passengerCount) as AvgPassenger, avg(TripData.TripTimeinSeconds) as TripTimeinSeconds, System.Timestamp as timestamps, TRY_CAST(HistoricalTrafficData.avgTraffic as bigint) as historicalTraffic \r\n\r\nINTO PBI \r\n\r\nFROM TripData \r\n\r\nJOIN HistoricalTrafficData ON \r\n\r\ndatepart(hour,TripData.pickupTime) = TRY_CAST(HistoricalTrafficData.hour as bigint) \r\n\r\nGroup By TripData.VendorID, HistoricalTrafficData.avgTraffic, hoppingwindow(second,60,5) ",
            "etag": "cc14703e-4d5f-489c-97e4-adf75698b20d"
          }
        },
        "functions": [],
        "outputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/asaClusterTest/outputs/output",
            "name": "output",
            "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
            "properties": {
              "datasource": {
                "type": "Microsoft.Storage/Blob",
                "properties": {
                  "storageAccounts": [
                    {
                      "accountName": "zhejuntest"
                    }
                  ],
                  "container": "output",
                  "pathPattern": "",
                  "dateFormat": "yyyy/MM/dd",
                  "timeFormat": "HH",
                  "authenticationMode": "ConnectionString"
                }
              },
              "timeWindow": "01:59:00",
              "sizeWindow": 1,
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8",
                  "format": "LineSeparated"
                }
              },
              "etag": "3632dbc3-1a8c-49dc-838d-1f84b709c667"
            }
          }
        ],
        "etag": "ba6f6d8e-57e2-45bd-87ba-2b62c259bbcc",
        "jobType": "Cloud",
        "cluster": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/clusters/zhejunASA"
        }
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest",
      "name": "ASAUDFTest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {},
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "8b39d20f-d8df-42e0-8198-a20160e4696b",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-16T05:56:55.51Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": {
          "authenticationMode": "ConnectionString",
          "accountName": "zhejuntest"
        },
        "contentStoragePolicy": "SystemAccount",
        "inputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest/inputs/Input",
            "name": "Input",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Stream",
              "datasource": {
                "type": "GatewayMessageBus"
              },
              "compression": {
                "type": "None"
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8"
                }
              },
              "etag": "34dcf5e8-d33e-4de3-b413-580fa9316f4b"
            }
          }
        ],
        "transformation": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest/transformations/Transformation",
          "name": "Transformation",
          "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
          "properties": {
            "streamingUnits": null,
            "query": "    SELECT machine.temperature, udf.ASAEdgeUDFDemo_Class1_SquareFunction(try_cast(machine.temperature as bigint))\r\n    INTO Output\r\n    FROM Input",
            "etag": "29beb753-10cb-4627-91df-09dbfea9ac77"
          }
        },
        "functions": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest/functions/ASAEdgeUDFDemo_Class1_SquareFunction",
            "name": "ASAEdgeUDFDemo_Class1_SquareFunction",
            "type": "Microsoft.StreamAnalytics/streamingjobs/functions",
            "properties": {
              "type": "Scalar",
              "properties": {
                "inputs": [
                  {
                    "dataType": "any",
                    "isConfigurationParameter": null
                  }
                ],
                "output": {
                  "dataType": "any"
                },
                "binding": {
                  "type": "Microsoft.StreamAnalytics/CLRUdf",
                  "properties": {
                    "dllPath": "ASAEdgeApplication2_CodeBehind",
                    "class": "ASAEdgeUDFDemo.Class1",
                    "method": "SquareFunction"
                  }
                }
              },
              "etag": "c3f6f31b-6b42-42c9-8cb1-1d12d6ab448a"
            }
          }
        ],
        "outputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/ASAUDFTest/outputs/Output",
            "name": "Output",
            "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
            "properties": {
              "datasource": {
                "type": "GatewayMessageBus"
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8",
                  "format": "Array"
                }
              },
              "etag": "c6ba3df6-13af-40af-992f-9317e8537590"
            }
          }
        ],
        "etag": "bfee3a7f-cdaf-4b1e-b449-71a3b8b4d6d9",
        "jobType": "Edge",
        "externals": {
          "storageAccount": {
            "accountName": "zhejuntest"
          },
          "container": "container2",
          "path": "UserCustomCode.zip"
        },
        "cluster": null
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest",
      "name": "zhejunmltest",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "aacee415-41d4-47f6-acf4-de9ae50175b0",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Drop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2020-07-17T08:36:07.463Z",
        "compatibilityLevel": "1.2",
        "jobStorageAccount": null,
        "contentStoragePolicy": "SystemAccount",
        "inputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/inputs/Input",
            "name": "Input",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Stream",
              "datasource": {
                "type": "Microsoft.Devices/IotHubs",
                "properties": {
                  "iotHubNamespace": "MyASAIoT",
                  "sharedAccessPolicyName": "iothubowner",
                  "endpoint": "messages/events",
                  "consumerGroupName": "$Default"
                }
              },
              "compression": {
                "type": "None"
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8"
                }
              },
              "etag": "3cb574f7-b63a-4ac1-a1db-8e8a3b88a20d"
            }
          }
        ],
        "transformation": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/transformations/Transformation",
          "name": "Transformation",
          "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
          "properties": {
            "streamingUnits": 3,
            "query": "\r\nWITH sentiment AS (  \r\nSELECT Temperature, diabetespredict(Temperature) as result \r\nFROM Input  \r\n)  \r\n\r\nSELECT Temperature, result.[Score]  \r\nINTO BlobOutput1\r\nFROM sentiment\r\n\r\n/*\r\nSELECT data, MLFunction2(data)\r\nFROM sampleRequestData\r\n*/\r\n/*\r\nSELECT data, AksArrayScore(data)\r\nFROM sampleData\r\n*/",
            "etag": "7241d411-e71d-4205-b77e-4cc56aba34c0"
          }
        },
        "functions": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/functions/diabetespredict",
            "name": "diabetespredict",
            "type": "Microsoft.StreamAnalytics/streamingjobs/functions",
            "properties": {
              "type": "Scalar",
              "properties": {
                "inputs": [
                  {
                    "dataType": "array",
                    "isConfigurationParameter": null
                  }
                ],
                "output": {
                  "dataType": "float"
                },
                "binding": {
                  "type": "Microsoft.MachineLearningServices",
                  "properties": {
                    "endpoint": "http://52.183.91.247/api/v1/service/aks-service-1/score",
                    "apiKey": null,
                    "inputs": [
                      {
                        "name": "data",
                        "dataType": "array",
                        "mapTo": 0
                      }
                    ],
                    "outputs": [
                      {
                        "name": "output",
                        "dataType": "double",
                        "mapTo": 0
                      }
                    ],
                    "batchSize": 1000,
                    "numberOfParallelRequests": 1
                  }
                }
              },
              "etag": "acfdd307-418c-48f3-8856-7c176d38529f"
            }
          },
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/functions/MLFunction2",
            "name": "MLFunction2",
            "type": "Microsoft.StreamAnalytics/streamingjobs/functions",
            "properties": {
              "type": "Scalar",
              "properties": {
                "inputs": [
                  {
                    "dataType": "array",
                    "isConfigurationParameter": null
                  }
                ],
                "output": {
                  "dataType": "float"
                },
                "binding": {
                  "type": "Microsoft.MachineLearningServices",
                  "properties": {
                    "endpoint": "http://13.83.67.157/api/v1/service/nyc-fare-predict/score",
                    "apiKey": null,
                    "inputs": [
                      {
                        "name": "data",
                        "dataType": "array",
                        "mapTo": 0
                      }
                    ],
                    "outputs": [
                      {
                        "name": "output",
                        "dataType": "double",
                        "mapTo": 0
                      }
                    ],
                    "batchSize": 1000,
                    "numberOfParallelRequests": 1
                  }
                }
              },
              "etag": "4d537fa6-f43c-4ee6-a45e-9a8f8002a65c"
            }
          },
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/functions/MLFunction3",
            "name": "MLFunction3",
            "type": "Microsoft.StreamAnalytics/streamingjobs/functions",
            "properties": {
              "type": "Scalar",
              "properties": {
                "inputs": [
                  {
                    "dataType": "array",
                    "isConfigurationParameter": null
                  }
                ],
                "output": {
                  "dataType": "float"
                },
                "binding": {
                  "type": "Microsoft.MachineLearningServices",
                  "properties": {
                    "endpoint": "http://52.183.91.247/api/v1/service/aks-service-1/score",
                    "apiKey": null,
                    "inputs": [
                      {
                        "name": "data",
                        "dataType": "array",
                        "mapTo": 0
                      }
                    ],
                    "outputs": [
                      {
                        "name": "output",
                        "dataType": "double",
                        "mapTo": 0
                      }
                    ],
                    "batchSize": 1000,
                    "numberOfParallelRequests": 1
                  }
                }
              },
              "etag": "912f08e7-4a8c-46eb-afaf-d88f930a7b45"
            }
          }
        ],
        "outputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/zhejunmltest/outputs/BlobOutput1",
            "name": "BlobOutput1",
            "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
            "properties": {
              "datasource": {
                "type": "Microsoft.Storage/Blob",
                "properties": {
                  "storageAccounts": [
                    {
                      "accountName": "zhejuntest2"
                    }
                  ],
                  "container": "output",
                  "pathPattern": "{date}{time}",
                  "dateFormat": "yyyy/MM/dd",
                  "timeFormat": "HH",
                  "authenticationMode": "ConnectionString"
                }
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8",
                  "format": "LineSeparated"
                }
              },
              "etag": "1c271cd5-dd4a-4d3e-95ee-1dbcaa530c2c"
            }
          }
        ],
        "etag": "89ba3a42-e217-432e-bf23-798dbf001519",
        "jobType": "Cloud",
        "cluster": null
      }
    }
  ],
  "nextLink": null
}

Definisi

AggregateFunctionProperties

Properti yang terkait dengan fungsi agregat.

AuthenticationMode

Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.

AvroSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.

AzureDataLakeStoreOutputDataSource

Menjelaskan sumber data output Azure Data Lake Store.

AzureFunctionOutputDataSource

Menentukan metadata AzureFunctionOutputDataSource

AzureMachineLearningServiceFunctionBinding

Pengikatan ke layanan web Azure Machine Learning.

AzureMachineLearningServiceInputColumn

Menjelaskan kolom input untuk titik akhir layanan web Azure Machine Learning.

AzureMachineLearningServiceOutputColumn

Menjelaskan kolom output untuk titik akhir layanan web Azure Machine Learning.

AzureMachineLearningStudioFunctionBinding

Pengikatan ke Azure Machine Learning Studio.

AzureMachineLearningStudioInputColumn

Menjelaskan kolom input untuk titik akhir Azure Machine Learning Studio.

AzureMachineLearningStudioInputs

Input untuk titik akhir Azure Machine Learning Studio.

AzureMachineLearningStudioOutputColumn

Menjelaskan kolom output untuk titik akhir Azure Machine Learning Studio.

AzureSqlDatabaseOutputDataSource

Menjelaskan sumber data output database Azure SQL.

AzureSqlReferenceInputDataSource

Menjelaskan sumber data input referensi database Azure SQL.

AzureSqlReferenceInputDataSourceProperties

Menjelaskan Azure SQL properti sumber data input referensi database.

AzureSynapseOutputDataSource

Menjelaskan sumber data output Azure Synapse.

AzureTableOutputDataSource

Menjelaskan sumber data output Tabel Azure.

BlobOutputDataSource

Menjelaskan sumber data output blob.

BlobReferenceInputDataSource

Menjelaskan sumber data input blob yang berisi data referensi.

BlobStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

ClusterInfo

Properti yang terkait dengan kluster Azure Stream Analytics.

CompatibilityLevel

Mengontrol perilaku runtime tertentu dari pekerjaan streaming.

Compression

Menjelaskan bagaimana data input dikompresi

ContentStoragePolicy

Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .

CSharpFunctionBinding

Pengikatan ke fungsi CSharp.

CsvSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.

CustomClrSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format kustom.

DiagnosticCondition

Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

DocumentDbOutputDataSource

Menjelaskan sumber data output DocumentDB.

Encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.

Error

Representasi kesalahan umum.

EventHubOutputDataSource

Menjelaskan sumber data output Event Hub.

EventHubStreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

EventHubV2OutputDataSource

Menjelaskan sumber data output Event Hub.

EventHubV2StreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

EventSerializationType

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

EventsOutOfOrderPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.

External

Akun penyimpanan tempat artefak kode kustom berada.

Function

Objek fungsi, berisi semua informasi yang terkait dengan fungsi bernama. Semua fungsi terkandung di bawah pekerjaan streaming.

FunctionInput

Menjelaskan satu parameter input fungsi.

FunctionOutput

Menjelaskan output fungsi.

Identity

Menjelaskan bagaimana identitas diverifikasi

Input

Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.

IoTHubStreamInputDataSource

Menjelaskan sumber data input IoT Hub yang berisi data aliran.

JavaScriptFunctionBinding

Pengikatan ke fungsi JavaScript.

JobStorageAccount

Properti yang terkait dengan akun Azure Storage dengan MSI

JobType

Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.

JsonOutputSerializationFormat

Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memformat setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.

JsonSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.

Output

Objek output, berisi semua informasi yang terkait dengan output bernama. Semua output terkandung di bawah pekerjaan streaming.

OutputErrorPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).

OutputStartMode

Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.

ParquetSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.

PowerBIOutputDataSource

Menjelaskan sumber data output Power BI.

RawOutputDatasource

Menjelaskan sumber data output mentah. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan output dari jenis sumber data ini ke pekerjaan yang sudah ada.

RawReferenceInputDataSource

Menjelaskan sumber data input mentah yang berisi data referensi. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan input tipe sumber data ini ke pekerjaan yang sudah ada.

RawStreamInputDataSource

Menjelaskan sumber data input mentah yang berisi data aliran. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan input tipe sumber data ini ke pekerjaan yang sudah ada.

ReferenceInputProperties

Properti yang terkait dengan input yang berisi data referensi.

ScalarFunctionProperties

Properti yang terkait dengan fungsi skalar.

ServiceBusQueueOutputDataSource

Menjelaskan sumber data output antrean Bus Layanan.

ServiceBusTopicOutputDataSource

Menjelaskan sumber data output Topik Bus Layanan.

StorageAccount

Properti yang terkait dengan akun Azure Storage

StreamingJob

Objek pekerjaan streaming, berisi semua informasi yang terkait dengan pekerjaan streaming bernama.

StreamingJobListResult

Objek yang berisi daftar pekerjaan streaming.

StreamingJobSku

Properti yang terkait dengan SKU.

StreamingJobSkuName

Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).

StreamInputProperties

Properti yang terkait dengan input yang berisi data aliran.

Transformation

Objek transformasi, berisi semua informasi yang terkait dengan transformasi bernama. Semua transformasi terkandung di bawah pekerjaan streaming.

AggregateFunctionProperties

Properti yang terkait dengan fungsi agregat.

Name Type Description
etag
  • string

Tag entitas saat ini untuk fungsi tersebut. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

properties.binding FunctionBinding:

Pengikatan fisik fungsi. Misalnya, dalam kasus layanan web Azure Machine Learning, ini menjelaskan titik akhir.

properties.inputs

Menjelaskan satu parameter input fungsi.

properties.output

Menjelaskan output fungsi.

type string:
  • Aggregate

Menunjukkan jenis fungsi.

AuthenticationMode

Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.

Name Type Description
ConnectionString
  • string
Msi
  • string
UserToken
  • string

AvroSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.

Name Type Description
type string:
  • Avro

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Menjelaskan sumber data output Azure Data Lake Store.

Name Type Default Value Description
properties.accountName
  • string

Nama akun Azure Data Lake Store. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.dateFormat
  • string

Format tanggal. Di mana pun {date} muncul di filePathPrefix, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.

properties.filePathPrefix
  • string

Lokasi file tempat output harus ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.refreshToken
  • string

Token refresh yang dapat digunakan untuk mendapatkan token akses valid yang kemudian dapat digunakan untuk mengautentikasi dengan sumber data. Token refresh yang valid saat ini hanya dapat diperoleh melalui Portal Microsoft Azure. Disarankan untuk menempatkan nilai string dummy di sini saat membuat sumber data lalu masuk ke Portal Microsoft Azure untuk mengautentikasi sumber data yang akan memperbarui properti ini dengan token refresh yang valid. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.tenantId
  • string

Id penyewa pengguna yang digunakan untuk mendapatkan token refresh. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.timeFormat
  • string

Format waktu. Di mana pun {time} muncul di filePathPrefix, nilai properti ini digunakan sebagai format waktu sebagai gantinya.

properties.tokenUserDisplayName
  • string

Nama tampilan pengguna pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.

properties.tokenUserPrincipalName
  • string

Nama prinsipal pengguna (UPN) pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.

type string:
  • Microsoft.DataLake/Accounts

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Menentukan metadata AzureFunctionOutputDataSource

Name Type Description
properties.apiKey
  • string

Jika Anda ingin menggunakan Fungsi Azure dari langganan lain, Anda bisa melakukannya dengan menyediakan kunci untuk mengakses fungsi Anda.

properties.functionAppName
  • string

Nama aplikasi Azure Functions Anda.

properties.functionName
  • string

Nama fungsi di aplikasi Azure Functions Anda.

properties.maxBatchCount
  • number

Properti yang memungkinkan Anda menentukan jumlah maksimum peristiwa di setiap batch yang dikirim ke Azure Functions. Nilai defaultnya adalah 100.

properties.maxBatchSize
  • number

Properti yang memungkinkan Anda mengatur ukuran maksimum untuk setiap batch output yang dikirim ke fungsi Azure Anda. Unit input berada di byte. Secara default, nilai ini diatur ke 262.144 byte (256 KB).

type string:
  • Microsoft.AzureFunction

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureMachineLearningServiceFunctionBinding

Pengikatan ke layanan web Azure Machine Learning.

Name Type Description
properties.apiKey
  • string

Kunci API yang digunakan untuk mengautentikasi dengan titik akhir Request-Response.

properties.batchSize
  • integer

Angka antara 1 dan 10000 yang menjelaskan jumlah maksimum baris untuk setiap permintaan eksekusi Azure ML RRS. Defaultnya adalah 1000.

properties.endpoint
  • string

Titik akhir eksekusi Request-Response layanan web Azure Machine Learning.

properties.inputs

Input untuk titik akhir layanan web Azure Machine Learning.

properties.numberOfParallelRequests
  • integer

Jumlah permintaan paralel yang akan dikirim per partisi pekerjaan Anda ke layanan pembelajaran mesin. Defaultnya adalah 1.

properties.outputs

Daftar output dari Azure Machine Learning eksekusi titik akhir layanan web.

type string:
  • Microsoft.MachineLearningServices

Menunjukkan jenis pengikatan fungsi.

AzureMachineLearningServiceInputColumn

Menjelaskan kolom input untuk titik akhir layanan web Azure Machine Learning.

Name Type Description
dataType
  • string

Jenis data (Azure Machine Learning didukung) dari kolom input.

mapTo
  • integer

Indeks berbasis nol dari parameter fungsi yang dipetakan input ini.

name
  • string

Nama kolom input.

AzureMachineLearningServiceOutputColumn

Menjelaskan kolom output untuk titik akhir layanan web Azure Machine Learning.

Name Type Description
dataType
  • string

Jenis data (Azure Machine Learning didukung) dari kolom output.

mapTo
  • integer

Indeks berbasis nol dari parameter fungsi yang dipetakan input ini.

name
  • string

Nama kolom output.

AzureMachineLearningStudioFunctionBinding

Pengikatan ke Azure Machine Learning Studio.

Name Type Description
properties.apiKey
  • string

Kunci API yang digunakan untuk mengautentikasi dengan titik akhir Request-Response.

properties.batchSize
  • integer

Angka antara 1 dan 10000 yang menjelaskan jumlah maksimum baris untuk setiap permintaan eksekusi Azure ML RRS. Defaultnya adalah 1000.

properties.endpoint
  • string

Titik akhir eksekusi Request-Response Azure Machine Learning Studio. Cari tahu lebih lanjut di sini: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs

properties.inputs

Input untuk titik akhir Azure Machine Learning Studio.

properties.outputs

Daftar output dari eksekusi titik akhir Azure Machine Learning Studio.

type string:
  • Microsoft.MachineLearning/WebService

Menunjukkan jenis pengikatan fungsi.

AzureMachineLearningStudioInputColumn

Menjelaskan kolom input untuk titik akhir Azure Machine Learning Studio.

Name Type Description
dataType
  • string

Jenis data (Azure Machine Learning didukung) dari kolom input. Daftar jenis data Azure Machine Learning yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .

mapTo
  • integer

Indeks berbasis nol dari parameter fungsi yang dipetakan input ini.

name
  • string

Nama kolom input.

AzureMachineLearningStudioInputs

Input untuk titik akhir Azure Machine Learning Studio.

Name Type Description
columnNames

Daftar kolom input untuk titik akhir Azure Machine Learning Studio.

name
  • string

Nama input. Ini adalah nama yang disediakan saat menulis titik akhir.

AzureMachineLearningStudioOutputColumn

Menjelaskan kolom output untuk titik akhir Azure Machine Learning Studio.

Name Type Description
dataType
  • string

Jenis data (Azure Machine Learning didukung) dari kolom output. Daftar jenis data Azure Machine Learning yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .

name
  • string

Nama kolom output.

AzureSqlDatabaseOutputDataSource

Menjelaskan sumber data output database Azure SQL.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.database
  • string

Nama database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.maxBatchCount
  • number

Jumlah Batch maks untuk menulis ke database Sql, nilai defaultnya adalah 10.000. Opsional pada permintaan PUT.

properties.maxWriterCount
  • number

Jumlah R Tulis Maks, saat ini hanya 1(penulis tunggal) dan 0(berdasarkan partisi kueri) yang tersedia. Opsional pada permintaan PUT.

properties.password
  • string

Kata sandi yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.server
  • string

Nama server SQL yang berisi database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.table
  • string

Nama tabel dalam database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.user
  • string

Nama pengguna yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.Sql/Server/Database

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Menjelaskan sumber data input referensi database Azure SQL.

Name Type Description
properties

Menjelaskan Azure SQL properti sumber data input referensi database.

type string:
  • Microsoft.Sql/Server/Database

Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureSqlReferenceInputDataSourceProperties

Menjelaskan Azure SQL properti sumber data input referensi database.

Name Type Description
database
  • string

Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama database tempat output akan ditulis.

deltaSnapshotQuery
  • string

Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil perubahan inkremental dari database SQL. Untuk menggunakan opsi ini, sebaiknya gunakan tabel temporal di Azure SQL Database.

fullSnapshotQuery
  • string

Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil data dari database sql.

password
  • string

Elemen ini dikaitkan dengan elemen sumber data. Ini adalah kata sandi yang akan digunakan untuk menyambungkan ke instans SQL Database.

refreshRate
  • string

Elemen ini dikaitkan dengan elemen sumber data. Ini menunjukkan seberapa sering data akan diambil dari database. Ini adalah format DateTime.

refreshType
  • string

Elemen ini dikaitkan dengan elemen sumber data. Elemen ini berjenis enum. Ini menunjukkan jenis opsi refresh data yang ingin kita gunakan:Static/RefreshPeriodicallyWithFull/RefreshPeriodicallyWithDelta

server
  • string

Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama server yang berisi database yang akan ditulis.

table
  • string

Elemen ini dikaitkan dengan elemen sumber data. Nama tabel dalam database Azure SQL..

user
  • string

Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama pengguna yang akan digunakan untuk menyambungkan ke instans SQL Database.

AzureSynapseOutputDataSource

Menjelaskan sumber data output Azure Synapse.

Name Type Description
properties.database
  • string

Nama database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.password
  • string

Kata sandi yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.server
  • string

Nama server SQL yang berisi database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.table
  • string

Nama tabel dalam database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.user
  • string

Nama pengguna yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.Sql/Server/DataWarehouse

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureTableOutputDataSource

Menjelaskan sumber data output Tabel Azure.

Name Type Description
properties.accountKey
  • string

Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.accountName
  • string

Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.batchSize
  • integer

Jumlah baris yang akan ditulis ke Tabel Azure pada satu waktu.

properties.columnsToRemove
  • string[]

Jika ditentukan, setiap item dalam array adalah nama kolom yang akan dihapus (jika ada) dari entitas peristiwa output.

properties.partitionKey
  • string

Elemen ini menunjukkan nama kolom dari pernyataan SELECT dalam kueri yang akan digunakan sebagai kunci partisi untuk Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.rowKey
  • string

Elemen ini menunjukkan nama kolom dari pernyataan SELECT dalam kueri yang akan digunakan sebagai kunci baris untuk Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.table
  • string

Nama Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.Storage/Table

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobOutputDataSource

Menjelaskan sumber data output blob.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.container
  • string

Nama kontainer dalam akun Storage terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.dateFormat
  • string

Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.

properties.pathPattern
  • string

Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.

properties.storageAccounts

Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.timeFormat
  • string

Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.

type string:
  • Microsoft.Storage/Blob

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobReferenceInputDataSource

Menjelaskan sumber data input blob yang berisi data referensi.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.container
  • string

Nama kontainer dalam akun Storage terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.dateFormat
  • string

Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.

properties.pathPattern
  • string

Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.

properties.storageAccounts

Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.timeFormat
  • string

Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.

type string:
  • Microsoft.Storage/Blob

Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.container
  • string

Nama kontainer dalam akun Storage terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.dateFormat
  • string

Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.

properties.pathPattern
  • string

Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.

properties.sourcePartitionCount
  • integer

Jumlah partisi sumber data input blob. Rentang 1 - 1024.

properties.storageAccounts

Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.timeFormat
  • string

Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.

type string:
  • Microsoft.Storage/Blob

Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

ClusterInfo

Properti yang terkait dengan kluster Azure Stream Analytics.

Name Type Description
id
  • string

Id sumber daya kluster.

CompatibilityLevel

Mengontrol perilaku runtime tertentu dari pekerjaan streaming.

Name Type Description
1.0
  • string

Compression

Menjelaskan bagaimana data input dikompresi

Name Type Description
type
  • string

ContentStoragePolicy

Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .

Name Type Description
JobStorageAccount
  • string
SystemAccount
  • string

CSharpFunctionBinding

Pengikatan ke fungsi CSharp.

Name Type Description
properties.class
  • string

Kode Csharp yang berisi definisi fungsi tunggal.

properties.dllPath
  • string

Kode Csharp yang berisi definisi fungsi tunggal.

properties.method
  • string

Kode Csharp yang berisi definisi fungsi tunggal.

properties.script
  • string

Kode Csharp yang berisi definisi fungsi tunggal.

type string:
  • Microsoft.StreamAnalytics/CLRUdf

Menunjukkan jenis pengikatan fungsi.

CsvSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.

Name Type Description
properties.encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.fieldDelimiter
  • string

Menentukan pemisah yang akan digunakan untuk memisahkan rekaman nilai yang dipisahkan koma (CSV). Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk daftar nilai yang didukung. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Csv

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

CustomClrSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format kustom.

Name Type Description
properties.serializationClassName
  • string

Nama kelas serialisasi.

properties.serializationDllPath
  • string

Jalur pustaka serialisasi.

type string:
  • CustomClr

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

DiagnosticCondition

Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Name Type Description
code
  • string

Kode diagnostik buram.

message
  • string

Pesan yang dapat dibaca manusia yang menjelaskan kondisi secara rinci. Dilokalkan dalam Accept-Language permintaan klien.

since
  • string

Tanda waktu UTC saat kondisi dimulai. Pelanggan harus dapat menemukan peristiwa yang sesuai dalam log ops sekitar waktu ini.

Diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Name Type Description
conditions

Kumpulan nol atau lebih kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

DocumentDbOutputDataSource

Menjelaskan sumber data output DocumentDB.

Name Type Description
properties.accountId
  • string

Nama akun atau ID DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.accountKey
  • string

Kunci akun untuk akun DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.collectionNamePattern
  • string

Pola nama koleksi untuk koleksi yang akan digunakan. Format nama koleksi dapat dibangun menggunakan token {partition} opsional, di mana partisi dimulai dari 0. Lihat bagian DocumentDB untuk https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output informasi selengkapnya. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.database
  • string

Nama database DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.documentId
  • string

Nama bidang dalam peristiwa output yang digunakan untuk menentukan kunci utama yang didasarkan pada operasi penyisipan atau pembaruan.

properties.partitionKey
  • string

Nama bidang dalam peristiwa output yang digunakan untuk menentukan kunci untuk mempartisi output di seluruh koleksi. Jika 'collectionNamePattern' berisi token {partition}, properti ini harus ditentukan.

type string:
  • Microsoft.Storage/DocumentDB

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

Encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.

Name Type Description
UTF8
  • string

Error

Representasi kesalahan umum.

Name Type Description
error

Properti definisi kesalahan.

EventHubOutputDataSource

Menjelaskan sumber data output Event Hub.

Name Type Default Value Description
authenticationMode ConnectionString

Mode Autentikasi.

properties.eventHubName
  • string

Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.partitionKey
  • string

Kunci/kolom yang digunakan untuk menentukan partisi mana yang akan mengirim data peristiwa.

properties.propertyColumns
  • string[]
serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.ServiceBus/EventHub

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubStreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Name Type Default Value Description
authenticationMode ConnectionString

Mode Autentikasi.

properties.consumerGroupName
  • string

Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.

properties.eventHubName
  • string

Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).

serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.ServiceBus/EventHub

Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubV2OutputDataSource

Menjelaskan sumber data output Event Hub.

Name Type Default Value Description
authenticationMode ConnectionString

Mode Autentikasi.

properties.eventHubName
  • string

Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.partitionKey
  • string

Kunci/kolom yang digunakan untuk menentukan partisi mana yang akan mengirim data peristiwa.

properties.propertyColumns
  • string[]
serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.EventHub/EventHub

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Name Type Default Value Description
authenticationMode ConnectionString

Mode Autentikasi.

properties.consumerGroupName
  • string

Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.

properties.eventHubName
  • string

Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).

serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.EventHub/EventHub

Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventSerializationType

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

Name Type Description
Avro
  • string
Csv
  • string
CustomClr
  • string
Json
  • string
Parquet
  • string

EventsOutOfOrderPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.

Name Type Description
Adjust
  • string
Drop
  • string

External

Akun penyimpanan tempat artefak kode kustom berada.

Name Type Description
container
  • string
path
  • string
storageAccount

Properti yang terkait dengan akun Azure Storage

Function

Objek fungsi, berisi semua informasi yang terkait dengan fungsi bernama. Semua fungsi terkandung di bawah pekerjaan streaming.

Name Type Description
id
  • string

ID sumber daya

name
  • string

Nama sumber daya

properties FunctionProperties:

Properti yang terkait dengan fungsi.

type
  • string

Jenis Sumber Daya

FunctionInput

Menjelaskan satu parameter input fungsi.

Name Type Description
dataType
  • string

Jenis data (didukung Azure Stream Analytics) dari parameter input fungsi. Daftar jenis data Azure Stream Analytics yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

isConfigurationParameter
  • boolean

Bendera yang menunjukkan apakah parameter adalah parameter konfigurasi. True jika parameter input ini diharapkan menjadi konstanta. Defaultnya adalah false.

FunctionOutput

Menjelaskan output fungsi.

Name Type Description
dataType
  • string

Jenis data (didukung Azure Stream Analytics) dari output fungsi. Daftar jenis data Azure Stream Analytics yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

Identity

Menjelaskan bagaimana identitas diverifikasi

Name Type Description
principalId
  • string
tenantId
  • string
type
  • string

Input

Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.

Name Type Description
id
  • string

ID sumber daya

name
  • string

Nama sumber daya

properties InputProperties:

Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace).

type
  • string

Jenis Sumber Daya

IoTHubStreamInputDataSource

Menjelaskan sumber data input IoT Hub yang berisi data aliran.

Name Type Description
properties.consumerGroupName
  • string

Nama Grup Konsumen IoT Hub yang harus digunakan untuk membaca peristiwa dari IoT Hub. Jika tidak ditentukan, input menggunakan grup konsumen default Iot Hub.

properties.endpoint
  • string

Titik akhir IoT Hub untuk disambungkan (yaitu pesan/peristiwa, pesan/operasiMonitoringEvents, dll.).

properties.iotHubNamespace
  • string

Nama atau URI IoT Hub. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk IoT Hub. Kebijakan ini harus berisi setidaknya izin Sambungan layanan. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.Devices/IotHubs

Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

JavaScriptFunctionBinding

Pengikatan ke fungsi JavaScript.

Name Type Description
properties.script
  • string

Kode JavaScript yang berisi definisi fungsi tunggal. Misalnya: 'function (x, y) { return x + y; }'

type string:
  • Microsoft.StreamAnalytics/JavascriptUdf

Menunjukkan jenis pengikatan fungsi.

JobStorageAccount

Properti yang terkait dengan akun Azure Storage dengan MSI

Name Type Default Value Description
accountKey
  • string

Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

accountName
  • string

Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

authenticationMode ConnectionString

Mode Autentikasi.

JobType

Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.

Name Type Description
Cloud
  • string
Edge
  • string

JsonOutputSerializationFormat

Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memformat setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.

Name Type Description
Array
  • string
LineSeparated
  • string

JsonSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.

Name Type Description
properties.encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.format

Properti ini hanya berlaku untuk serialisasi JSON output saja. Ini tidak berlaku untuk input. Properti ini menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memformat setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON. Nilai default adalah 'lineSeparated' jika dibiarkan null.

type string:
  • Json

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

Output

Objek output, berisi semua informasi yang terkait dengan output bernama. Semua output terkandung di bawah pekerjaan streaming.

Name Type Description
id
  • string

ID sumber daya

name
  • string

Nama sumber daya

properties.datasource OutputDataSource:

Menjelaskan sumber data tempat output akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

properties.etag
  • string

Tag entitas saat ini untuk output. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

properties.serialization Serialization:

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sizeWindow
  • number
properties.timeWindow
  • string
type
  • string

Jenis Sumber Daya

OutputErrorPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).

Name Type Description
Drop
  • string
Stop
  • string

OutputStartMode

Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.

Name Type Description
CustomTime
  • string
JobStartTime
  • string
LastOutputEventTime
  • string

ParquetSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.

Name Type Description
type string:
  • Parquet

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

PowerBIOutputDataSource

Menjelaskan sumber data output Power BI.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.dataset
  • string

Nama himpunan data Power BI. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.groupId
  • string

ID grup Power BI.

properties.groupName
  • string

Nama grup Power BI. Gunakan properti ini untuk membantu mengingat id grup Power BI tertentu mana yang digunakan.

properties.refreshToken
  • string

Token refresh yang dapat digunakan untuk mendapatkan token akses valid yang kemudian dapat digunakan untuk mengautentikasi dengan sumber data. Token refresh yang valid saat ini hanya dapat diperoleh melalui Portal Microsoft Azure. Disarankan untuk menempatkan nilai string dummy di sini saat membuat sumber data lalu masuk ke Portal Microsoft Azure untuk mengautentikasi sumber data yang akan memperbarui properti ini dengan token refresh yang valid. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.table
  • string

Nama tabel Power BI di bawah himpunan data yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.tokenUserDisplayName
  • string

Nama tampilan pengguna pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.

properties.tokenUserPrincipalName
  • string

Nama prinsipal pengguna (UPN) pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.

type string:
  • PowerBI

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

RawOutputDatasource

Menjelaskan sumber data output mentah. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan output dari jenis sumber data ini ke pekerjaan yang sudah ada.

Name Type Description
properties.payloadUri
  • string

URL SAS ke blob tempat output harus ditulis. Jika properti ini tidak diatur, data output akan ditulis ke dalam penyimpanan sementara, dan URL SAS ke penyimpanan sementara tersebut akan disertakan dalam hasilnya.

type string:
  • Raw

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

RawReferenceInputDataSource

Menjelaskan sumber data input mentah yang berisi data referensi. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan input tipe sumber data ini ke pekerjaan yang sudah ada.

Name Type Description
properties.payload
  • string

Konten berseri JSON dari data input. Payload atau payloadUri harus diatur, tetapi tidak keduanya.

properties.payloadUri
  • string

URL SAS ke blob yang berisi konten berseri JSON dari data input. Payload atau payloadUri harus diatur, tetapi tidak keduanya.

type string:
  • Raw

Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

RawStreamInputDataSource

Menjelaskan sumber data input mentah yang berisi data aliran. Jenis sumber data ini hanya berlaku/dapat digunakan saat menggunakan API pengujian kueri. Anda tidak dapat membuat pekerjaan dengan tipe sumber data ini atau menambahkan input tipe sumber data ini ke pekerjaan yang sudah ada.

Name Type Description
properties.payload
  • string

Konten berseri JSON dari data input. Payload atau payloadUri harus diatur, tetapi tidak keduanya.

properties.payloadUri
  • string

URL SAS ke blob yang berisi konten berseri JSON dari data input. Payload atau payloadUri harus diatur, tetapi tidak keduanya.

type string:
  • Raw

Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

ReferenceInputProperties

Properti yang terkait dengan input yang berisi data referensi.

Name Type Description
compression

Menjelaskan bagaimana data input dikompresi

datasource ReferenceInputDataSource:

Menjelaskan sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

etag
  • string

Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

partitionKey
  • string

partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input

serialization Serialization:

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Reference

Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

ScalarFunctionProperties

Properti yang terkait dengan fungsi skalar.

Name Type Description
etag
  • string

Tag entitas saat ini untuk fungsi tersebut. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

properties.binding FunctionBinding:

Pengikatan fisik fungsi. Misalnya, dalam kasus layanan web Azure Machine Learning, ini menjelaskan titik akhir.

properties.inputs

Menjelaskan satu parameter input fungsi.

properties.output

Menjelaskan output fungsi.

type string:
  • Scalar

Menunjukkan jenis fungsi.

ServiceBusQueueOutputDataSource

Menjelaskan sumber data output antrean Bus Layanan.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.propertyColumns
  • string[]

Array string dari nama kolom output yang akan dilampirkan ke pesan Bus Layanan sebagai properti kustom.

properties.queueName
  • string

Nama Antrean Bus Layanan. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.systemPropertyColumns
  • object
type string:
  • Microsoft.ServiceBus/Queue

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Menjelaskan sumber data output Topik Bus Layanan.

Name Type Default Value Description
properties.authenticationMode ConnectionString

Mode Autentikasi.

properties.propertyColumns
  • string[]

Array string dari nama kolom output yang akan dilampirkan ke pesan Bus Layanan sebagai properti kustom.

properties.serviceBusNamespace
  • string

Namespace layanan yang terkait dengan Pusat Aktivitas yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyKey
  • string

Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.sharedAccessPolicyName
  • string

Nama kebijakan akses bersama untuk Event Hub, Bus Layanan Queue, Bus Layanan Topic, dll. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.systemPropertyColumns
  • object
properties.topicName
  • string

Nama Topik Bus Layanan. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Microsoft.ServiceBus/Topic

Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

StorageAccount

Properti yang terkait dengan akun Azure Storage

Name Type Description
accountKey
  • string

Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

accountName
  • string

Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

StreamingJob

Objek pekerjaan streaming, berisi semua informasi yang terkait dengan pekerjaan streaming bernama.

Name Type Description
id
  • string

Id sumber daya yang sepenuhnya memenuhi syarat untuk sumber daya. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}

identity

Menjelaskan identitas terkelola yang ditetapkan sistem yang ditetapkan untuk pekerjaan ini yang dapat digunakan untuk mengautentikasi dengan input dan output.

location
  • string

Lokasi geografis tempat sumber daya berada

name
  • string

Nama sumber daya.

properties.cluster

Kluster tempat pekerjaan streaming akan berjalan.

properties.compatibilityLevel

Mengontrol perilaku runtime tertentu dari pekerjaan streaming.

properties.contentStoragePolicy

Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .

properties.createdDate
  • string

Nilai adalah tanda waktu UTC berformat ISO-8601 yang menunjukkan kapan pekerjaan streaming dibuat.

properties.dataLocale
  • string

Lokal data dari pekerjaan analitik stream. Nilai harus menjadi nama .NET Culture yang didukung dari set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Tentukan default ke 'en-US' jika tidak ditentukan.

properties.etag
  • string

Tag entitas saat ini untuk pekerjaan streaming. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

properties.eventsLateArrivalMaxDelayInSeconds
  • integer

Maksimum penundaan yang dapat ditoleransi dalam hitungan detik agar peristiwa yang datang terlambat dapat disertakan. Rentang yang didukung adalah -1 hingga 1814399 (20.23:59:59 hari) dan -1 digunakan untuk menentukan tunggu tanpa batas waktu. Jika properti tidak ada, peristiwa dianggap memiliki nilai -1.

properties.eventsOutOfOrderMaxDelayInSeconds
  • integer

Penundaan maksimum yang dapat ditoleransi dalam hitungan detik agar peristiwa yang keluar dari urutan dapat disesuaikan kembali ke dalam urutan.

properties.eventsOutOfOrderPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.

properties.externals

Akun penyimpanan tempat artefak kode kustom berada.

properties.functions

Daftar satu atau beberapa fungsi untuk pekerjaan streaming. Properti nama untuk setiap fungsi diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk transformasi individual.

properties.inputs

Daftar satu atau beberapa input ke pekerjaan streaming. Properti nama untuk setiap input diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk input individual.

properties.jobId
  • string

GUID secara unik mengidentifikasi pekerjaan streaming. GUID ini dihasilkan setelah pembuatan pekerjaan streaming.

properties.jobState
  • string

Menjelaskan status pekerjaan streaming.

properties.jobStorageAccount

Properti yang terkait dengan akun Azure Storage dengan MSI

properties.jobType

Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.

properties.lastOutputEventTime
  • string

Nilai adalah tanda waktu berformat ISO-8601 yang menunjukkan waktu peristiwa output terakhir dari pekerjaan streaming atau null yang menunjukkan bahwa output belum diproduksi. Dalam kasus beberapa output atau beberapa aliran, ini menunjukkan nilai terbaru dalam set tersebut.

properties.outputErrorPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).

properties.outputStartMode

Properti ini hanya boleh digunakan ketika diinginkan bahwa pekerjaan segera dimulai setelah pembuatan. Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.

properties.outputStartTime
  • string

Nilai adalah stempel waktu berformat ISO-8601 yang menunjukkan titik awal aliran peristiwa output, atau null untuk menunjukkan bahwa aliran peristiwa output akan dimulai setiap kali pekerjaan streaming dimulai. Properti ini harus memiliki nilai jika outputStartMode diatur ke CustomTime.

properties.outputs

Daftar satu atau beberapa output untuk pekerjaan streaming. Properti nama untuk setiap output diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk output individual.

properties.provisioningState
  • string

Menjelaskan status provisi pekerjaan streaming.

properties.sku

Menjelaskan SKU pekerjaan streaming. Diperlukan pada permintaan PUT (CreateOrReplace).

properties.transformation

Menunjukkan kueri dan jumlah unit streaming yang akan digunakan untuk pekerjaan streaming. Properti nama transformasi diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk transformasi individual.

tags
  • object

Tag sumber daya.

type
  • string

Jenis sumber daya. Ex- Microsoft.Compute/virtualMachines atau Microsoft. Storage/storageAccounts.

StreamingJobListResult

Objek yang berisi daftar pekerjaan streaming.

Name Type Description
nextLink
  • string

Tautan (url) ke halaman hasil berikutnya.

value

Daftar pekerjaan streaming. Diisi oleh operasi 'Daftar'.

StreamingJobSku

Properti yang terkait dengan SKU.

Name Type Description
name

Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).

StreamingJobSkuName

Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).

Name Type Description
Standard
  • string

StreamInputProperties

Properti yang terkait dengan input yang berisi data aliran.

Name Type Description
compression

Menjelaskan bagaimana data input dikompresi

datasource StreamInputDataSource:

Menjelaskan sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

etag
  • string

Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

partitionKey
  • string

partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input

serialization Serialization:

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).

type string:
  • Stream

Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

Transformation

Objek transformasi, berisi semua informasi yang terkait dengan transformasi bernama. Semua transformasi terkandung di bawah pekerjaan streaming.

Name Type Description
id
  • string

ID sumber daya

name
  • string

Nama sumber daya

properties.etag
  • string

Tag entitas saat ini untuk transformasi. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.

properties.query
  • string

Menentukan kueri yang akan dijalankan dalam pekerjaan streaming. Anda dapat mempelajari selengkapnya tentang Bahasa Kueri Azure Stream Analytics (SAQL) di sini: https://msdn.microsoft.com/library/azure/dn834998 . Diperlukan pada permintaan PUT (CreateOrReplace).

properties.streamingUnits
  • integer

Menentukan jumlah unit streaming yang digunakan pekerjaan streaming.

type
  • string

Jenis Sumber Daya