Microsoft.StreamAnalytics ストリーミングジョブ

2025-05-14

Bicep リソース定義

streamingjobs リソースの種類は、次を対象とする操作と共にデプロイできます。

リソースグループの - リソースグループのデプロイコマンド参照

各 API バージョンで変更されたプロパティの一覧については、変更ログの参照してください。

リソースの形式

Microsoft.StreamAnalytics/streamingjobs リソースを作成するには、次の Bicep をテンプレートに追加します。

resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview' = {
  identity: {
    type: 'string'
    userAssignedIdentities: {
      {customized property}: any(...)
    }
  }
  location: 'string'
  name: 'string'
  properties: {
    cluster: {
      id: 'string'
    }
    compatibilityLevel: 'string'
    contentStoragePolicy: 'string'
    dataLocale: 'string'
    eventsLateArrivalMaxDelayInSeconds: int
    eventsOutOfOrderMaxDelayInSeconds: int
    eventsOutOfOrderPolicy: 'string'
    externals: {
      container: 'string'
      path: 'string'
      refreshConfiguration: {
        dateFormat: 'string'
        pathPattern: 'string'
        refreshInterval: 'string'
        refreshType: 'string'
        timeFormat: 'string'
      }
      storageAccount: {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    }
    functions: [
      {
        name: 'string'
        properties: {
          properties: {
            binding: {
              type: 'string'
              // For remaining properties, see FunctionBinding objects
            }
            inputs: [
              {
                dataType: 'string'
                isConfigurationParameter: bool
              }
            ]
            output: {
              dataType: 'string'
            }
          }
          type: 'string'
          // For remaining properties, see FunctionProperties objects
        }
      }
    ]
    inputs: [
      {
        name: 'string'
        properties: {
          compression: {
            type: 'string'
          }
          partitionKey: 'string'
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          watermarkSettings: {
            watermarkMode: 'string'
          }
          type: 'string'
          // For remaining properties, see InputProperties objects
        }
      }
    ]
    jobStorageAccount: {
      accountKey: 'string'
      accountName: 'string'
      authenticationMode: 'string'
    }
    jobType: 'string'
    outputErrorPolicy: 'string'
    outputs: [
      {
        name: 'string'
        properties: {
          datasource: {
            type: 'string'
            // For remaining properties, see OutputDataSource objects
          }
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          sizeWindow: int
          timeWindow: 'string'
          watermarkSettings: {
            maxWatermarkDifferenceAcrossPartitions: 'string'
            watermarkMode: 'string'
          }
        }
      }
    ]
    outputStartMode: 'string'
    outputStartTime: 'string'
    sku: {
      capacity: int
      name: 'string'
    }
    transformation: {
      name: 'string'
      properties: {
        query: 'string'
        streamingUnits: int
        validStreamingUnits: [
          int
        ]
      }
    }
  }
  sku: {
    capacity: int
    name: 'string'
  }
  tags: {
    {customized property}: 'string'
  }
}

FunctionProperties オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

集計の場合は、次の値を使用します。

{
  type: 'Aggregate'
}

スカラーの場合は、次の値を使用します。

{
  type: 'Scalar'
}

シリアル化オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

Avroをする場合は、次を使用します。

{
  properties: any(...)
  type: 'Avro'
}

Csv の場合は、次を使用します。

{
  properties: {
    encoding: 'string'
    fieldDelimiter: 'string'
  }
  type: 'Csv'
}

CustomClr の場合は、次を使用します。

{
  properties: {
    serializationClassName: 'string'
    serializationDllPath: 'string'
  }
  type: 'CustomClr'
}

Delta の場合は、次の値を使用します。

{
  properties: {
    deltaTablePath: 'string'
    partitionColumns: [
      'string'
    ]
  }
  type: 'Delta'
}

Json の場合は、次を使用します。

{
  properties: {
    encoding: 'string'
    format: 'string'
  }
  type: 'Json'
}

Parquet場合は、次を使用します。

{
  properties: any(...)
  type: 'Parquet'
}

FunctionBinding オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

Microsoft.MachineLearning/WebService の場合は、次を使用します。

{
  properties: {
    apiKey: 'string'
    batchSize: int
    endpoint: 'string'
    inputs: {
      columnNames: [
        {
          dataType: 'string'
          mapTo: int
          name: 'string'
        }
      ]
      name: 'string'
    }
    outputs: [
      {
        dataType: 'string'
        name: 'string'
      }
    ]
  }
  type: 'Microsoft.MachineLearning/WebService'
}

Microsoft.MachineLearningServices の場合は、次を使用します。

{
  properties: {
    apiKey: 'string'
    batchSize: int
    endpoint: 'string'
    inputRequestName: 'string'
    inputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
    numberOfParallelRequests: int
    outputResponseName: 'string'
    outputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
  }
  type: 'Microsoft.MachineLearningServices'
}

Microsoft.StreamAnalytics/CLRUdf の場合は、次を使用します。

{
  properties: {
    class: 'string'
    dllPath: 'string'
    method: 'string'
    updateMode: 'string'
  }
  type: 'Microsoft.StreamAnalytics/CLRUdf'
}

Microsoft.StreamAnalytics/JavascriptUdf の場合は、次を使用します。

{
  properties: {
    script: 'string'
  }
  type: 'Microsoft.StreamAnalytics/JavascriptUdf'
}

OutputDataSource オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

GatewayMessageBus の場合は、次を使用します。

{
  properties: {
    topic: 'string'
  }
  type: 'GatewayMessageBus'
}

Microsoft.AzureFunctionをする場合は、次を使用します。

{
  properties: {
    apiKey: 'string'
    functionAppName: 'string'
    functionName: 'string'
    maxBatchCount: int
    maxBatchSize: int
  }
  type: 'Microsoft.AzureFunction'
}

Microsoft.DBForPostgreSQL/servers/databases の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    maxWriterCount: int
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }
  type: 'Microsoft.DBForPostgreSQL/servers/databases'
}

Microsoft.DataLake/Accounts の場合は、次を使用します。

{
  properties: {
    accountName: 'string'
    authenticationMode: 'string'
    dateFormat: 'string'
    filePathPrefix: 'string'
    refreshToken: 'string'
    tenantId: 'string'
    timeFormat: 'string'
    tokenUserDisplayName: 'string'
    tokenUserPrincipalName: 'string'
  }
  type: 'Microsoft.DataLake/Accounts'
}

Microsoft.EventHub/EventHubをする場合は、次の値を使用します。

{
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.EventHub/EventHub'
}

Microsoft.Kusto/clusters/databases の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    cluster: 'string'
    database: 'string'
    table: 'string'
  }
  type: 'Microsoft.Kusto/clusters/databases'
}

Microsoft.ServiceBus/EventHub の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.ServiceBus/EventHub'
}

Microsoft.ServiceBus/Queueの場合は、次の値を使用します。

{
  properties: {
    authenticationMode: 'string'
    propertyColumns: [
      'string'
    ]
    queueName: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
    systemPropertyColumns: any(...)
  }
  type: 'Microsoft.ServiceBus/Queue'
}

Microsoft.ServiceBus/Topicの場合は、次の値を使用します。

{
  properties: {
    authenticationMode: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
    systemPropertyColumns: {
      {customized property}: 'string'
    }
    topicName: 'string'
  }
  type: 'Microsoft.ServiceBus/Topic'
}

Microsoft.Sql/Server/DataWarehouseの場合は、次の値を使用します。

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }
  type: 'Microsoft.Sql/Server/DataWarehouse'
}

Microsoft.Sql/Server/Database の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    maxBatchCount: int
    maxWriterCount: int
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }
  type: 'Microsoft.Sql/Server/Database'
}

Microsoft.Storage/BLOB の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    blobPathPrefix: 'string'
    blobWriteMode: 'string'
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    timeFormat: 'string'
  }
  type: 'Microsoft.Storage/Blob'
}

Microsoft.Storage/DocumentDBをする場合は、次の値を使用します。

{
  properties: {
    accountId: 'string'
    accountKey: 'string'
    authenticationMode: 'string'
    collectionNamePattern: 'string'
    database: 'string'
    documentId: 'string'
    partitionKey: 'string'
  }
  type: 'Microsoft.Storage/DocumentDB'
}

Microsoft.Storage/Table の場合は、次を使用します。

{
  properties: {
    accountKey: 'string'
    accountName: 'string'
    batchSize: int
    columnsToRemove: [
      'string'
    ]
    partitionKey: 'string'
    rowKey: 'string'
    table: 'string'
  }
  type: 'Microsoft.Storage/Table'
}

PowerBI の場合は、次のコマンドを使用します。

{
  properties: {
    authenticationMode: 'string'
    dataset: 'string'
    groupId: 'string'
    groupName: 'string'
    refreshToken: 'string'
    table: 'string'
    tokenUserDisplayName: 'string'
    tokenUserPrincipalName: 'string'
  }
  type: 'PowerBI'
}

Raw の場合は、次の値を使用します。

{
  properties: {
    payloadUri: 'string'
  }
  type: 'Raw'
}

ReferenceInputDataSource オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

ファイルの場合は、次を使用します。

{
  properties: {
    path: 'string'
  }
  type: 'File'
}

Microsoft.Sql/Server/Database の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    deltaSnapshotQuery: 'string'
    fullSnapshotQuery: 'string'
    password: 'string'
    refreshRate: 'string'
    refreshType: 'string'
    server: 'string'
    user: 'string'
  }
  type: 'Microsoft.Sql/Server/Database'
}

Microsoft.Storage/BLOB の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    blobName: 'string'
    container: 'string'
    dateFormat: 'string'
    deltaPathPattern: 'string'
    deltaSnapshotRefreshRate: 'string'
    fullSnapshotRefreshRate: 'string'
    pathPattern: 'string'
    sourcePartitionCount: int
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    timeFormat: 'string'
  }
  type: 'Microsoft.Storage/Blob'
}

Raw の場合は、次の値を使用します。

{
  properties: {
    payload: 'string'
    payloadUri: 'string'
  }
  type: 'Raw'
}

InputProperties オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

参考までに、次の値を使用します。

{
  datasource: {
    type: 'string'
    // For remaining properties, see ReferenceInputDataSource objects
  }
  type: 'Reference'
}

Stream の場合は、次を使用します。

{
  datasource: {
    type: 'string'
    // For remaining properties, see StreamInputDataSource objects
  }
  type: 'Stream'
}

StreamInputDataSource オブジェクト

型プロパティを設定して、オブジェクトの型を指定します。

GatewayMessageBus の場合は、次を使用します。

{
  properties: {
    topic: 'string'
  }
  type: 'GatewayMessageBus'
}

Microsoft.Devices/IotHubs の場合は、次を使用します。

{
  properties: {
    consumerGroupName: 'string'
    endpoint: 'string'
    iotHubNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.Devices/IotHubs'
}

Microsoft.EventGrid/EventSubscriptions の場合は、次を使用します。

{
  properties: {
    eventTypes: [
      'string'
    ]
    schema: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    subscriber: {
      properties: {
        authenticationMode: 'string'
        consumerGroupName: 'string'
        eventHubName: 'string'
        partitionCount: int
        prefetchCount: int
        serviceBusNamespace: 'string'
        sharedAccessPolicyKey: 'string'
        sharedAccessPolicyName: 'string'
      }
      type: 'string'
    }
  }
  type: 'Microsoft.EventGrid/EventSubscriptions'
}

Microsoft.EventHub/EventHubをする場合は、次の値を使用します。

{
  properties: {
    authenticationMode: 'string'
    consumerGroupName: 'string'
    eventHubName: 'string'
    partitionCount: int
    prefetchCount: int
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.EventHub/EventHub'
}

Microsoft.ServiceBus/EventHub の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    consumerGroupName: 'string'
    eventHubName: 'string'
    partitionCount: int
    prefetchCount: int
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.ServiceBus/EventHub'
}

Microsoft.Storage/BLOB の場合は、次を使用します。

{
  properties: {
    authenticationMode: 'string'
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    sourcePartitionCount: int
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    timeFormat: 'string'
  }
  type: 'Microsoft.Storage/Blob'
}

Raw の場合は、次の値を使用します。

{
  properties: {
    payload: 'string'
    payloadUri: 'string'
  }
  type: 'Raw'
}

プロパティ値