import * as pulumi from "@pulumi/pulumi"; /** * Manages a Kusto (also known as Azure Data Explorer) EventHub Data Connection * * ## Example Usage * * ```typescript * import * as pulumi from "@pulumi/pulumi"; * import * as azure from "@pulumi/azure"; * * const example = new azure.core.ResourceGroup("example", { * name: "my-kusto-rg", * location: "West Europe", * }); * const cluster = new azure.kusto.Cluster("cluster", { * name: "kustocluster", * location: example.location, * resourceGroupName: example.name, * sku: { * name: "Standard_D13_v2", * capacity: 2, * }, * }); * const database = new azure.kusto.Database("database", { * name: "my-kusto-database", * resourceGroupName: example.name, * location: example.location, * clusterName: cluster.name, * hotCachePeriod: "P7D", * softDeletePeriod: "P31D", * }); * const eventhubNs = new azure.eventhub.EventHubNamespace("eventhub_ns", { * name: "my-eventhub-ns", * location: example.location, * resourceGroupName: example.name, * sku: "Standard", * }); * const eventhub = new azure.eventhub.EventHub("eventhub", { * name: "my-eventhub", * namespaceId: eventhubNs.id, * partitionCount: 1, * messageRetention: 1, * }); * const consumerGroup = new azure.eventhub.ConsumerGroup("consumer_group", { * name: "my-eventhub-consumergroup", * namespaceName: eventhubNs.name, * eventhubName: eventhub.name, * resourceGroupName: example.name, * }); * const eventhubConnection = new azure.kusto.EventhubDataConnection("eventhub_connection", { * name: "my-kusto-eventhub-data-connection", * resourceGroupName: example.name, * location: example.location, * clusterName: cluster.name, * databaseName: database.name, * eventhubId: eventhub.id, * consumerGroup: consumerGroup.name, * tableName: "my-table", * mappingRuleName: "my-table-mapping", * dataFormat: "JSON", * retrievalStartDate: "2023-06-26T12:00:00Z", * }); * ``` * * ## API Providers * * * This resource uses the following Azure API Providers: * * * `Microsoft.Kusto` - 2024-04-13 * * ## Import * * Kusto EventHub Data Connections can be imported using the `resource id`, e.g. * * ```sh * $ pulumi import azure:kusto/eventhubDataConnection:EventhubDataConnection example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.Kusto/clusters/cluster1/databases/database1/dataConnections/eventHubConnection1 * ``` */ export declare class EventhubDataConnection extends pulumi.CustomResource { /** * Get an existing EventhubDataConnection resource's state with the given name, ID, and optional extra * properties used to qualify the lookup. * * @param name The _unique_ name of the resulting resource. * @param id The _unique_ provider ID of the resource to lookup. * @param state Any extra arguments used during the lookup. * @param opts Optional settings to control the behavior of the CustomResource. */ static get(name: string, id: pulumi.Input, state?: EventhubDataConnectionState, opts?: pulumi.CustomResourceOptions): EventhubDataConnection; /** * Returns true if the given object is an instance of EventhubDataConnection. This is designed to work even * when multiple copies of the Pulumi SDK have been loaded into the same process. */ static isInstance(obj: any): obj is EventhubDataConnection; /** * Specifies the name of the Kusto Cluster this data connection will be added to. Changing this forces a new resource to be created. */ readonly clusterName: pulumi.Output; /** * Specifies compression type for the connection. Allowed values: `GZip` and `None`. Defaults to `None`. Changing this forces a new resource to be created. */ readonly compression: pulumi.Output; /** * Specifies the EventHub consumer group this data connection will use for ingestion. Changing this forces a new resource to be created. */ readonly consumerGroup: pulumi.Output; /** * Specifies the data format of the EventHub messages. Allowed values: `APACHEAVRO`, `AVRO`, `CSV`, `JSON`, `MULTIJSON`, `ORC`, `PARQUET`, `PSV`, `RAW`, `SCSV`, `SINGLEJSON`, `SOHSV`, `TSVE`, `TSV`, `TXT`, and `W3CLOGFILE`. */ readonly dataFormat: pulumi.Output; /** * Specifies the name of the Kusto Database this data connection will be added to. Changing this forces a new resource to be created. */ readonly databaseName: pulumi.Output; /** * Indication for database routing information from the data connection, by default only database routing information is allowed. Allowed values: `Single`, `Multi`. Changing this forces a new resource to be created. Defaults to `Single`. */ readonly databaseRoutingType: pulumi.Output; /** * Specifies a list of system properties for the Event Hub. */ readonly eventSystemProperties: pulumi.Output; /** * Specifies the resource id of the EventHub this data connection will use for ingestion. Changing this forces a new resource to be created. */ readonly eventhubId: pulumi.Output; /** * The resource ID of a managed identity (system or user assigned) to be used to authenticate with event hub. */ readonly identityId: pulumi.Output; /** * The location where the Kusto Database should be created. Changing this forces a new resource to be created. */ readonly location: pulumi.Output; /** * Specifies the mapping rule used for the message ingestion. Mapping rule must exist before resource is created. */ readonly mappingRuleName: pulumi.Output; /** * The name of the Kusto EventHub Data Connection to create. Changing this forces a new resource to be created. */ readonly name: pulumi.Output; /** * Specifies the Resource Group where the Kusto Database should exist. Changing this forces a new resource to be created. */ readonly resourceGroupName: pulumi.Output; /** * Specifies the date after which data should be retrieved from Event Hub. When defined, the data connection retrieves existing events created since the specified retrieval start date. It can only retrieve events retained by the Event Hub, based on its retention period. The value should be in RFC3339 format (e.g., `2023-06-26T12:00:00Z`). */ readonly retrievalStartDate: pulumi.Output; /** * Specifies the target table name used for the message ingestion. Table must exist before resource is created. */ readonly tableName: pulumi.Output; /** * Create a EventhubDataConnection resource with the given unique name, arguments, and options. * * @param name The _unique_ name of the resource. * @param args The arguments to use to populate this resource's properties. * @param opts A bag of options that control this resource's behavior. */ constructor(name: string, args: EventhubDataConnectionArgs, opts?: pulumi.CustomResourceOptions); } /** * Input properties used for looking up and filtering EventhubDataConnection resources. */ export interface EventhubDataConnectionState { /** * Specifies the name of the Kusto Cluster this data connection will be added to. Changing this forces a new resource to be created. */ clusterName?: pulumi.Input; /** * Specifies compression type for the connection. Allowed values: `GZip` and `None`. Defaults to `None`. Changing this forces a new resource to be created. */ compression?: pulumi.Input; /** * Specifies the EventHub consumer group this data connection will use for ingestion. Changing this forces a new resource to be created. */ consumerGroup?: pulumi.Input; /** * Specifies the data format of the EventHub messages. Allowed values: `APACHEAVRO`, `AVRO`, `CSV`, `JSON`, `MULTIJSON`, `ORC`, `PARQUET`, `PSV`, `RAW`, `SCSV`, `SINGLEJSON`, `SOHSV`, `TSVE`, `TSV`, `TXT`, and `W3CLOGFILE`. */ dataFormat?: pulumi.Input; /** * Specifies the name of the Kusto Database this data connection will be added to. Changing this forces a new resource to be created. */ databaseName?: pulumi.Input; /** * Indication for database routing information from the data connection, by default only database routing information is allowed. Allowed values: `Single`, `Multi`. Changing this forces a new resource to be created. Defaults to `Single`. */ databaseRoutingType?: pulumi.Input; /** * Specifies a list of system properties for the Event Hub. */ eventSystemProperties?: pulumi.Input[]>; /** * Specifies the resource id of the EventHub this data connection will use for ingestion. Changing this forces a new resource to be created. */ eventhubId?: pulumi.Input; /** * The resource ID of a managed identity (system or user assigned) to be used to authenticate with event hub. */ identityId?: pulumi.Input; /** * The location where the Kusto Database should be created. Changing this forces a new resource to be created. */ location?: pulumi.Input; /** * Specifies the mapping rule used for the message ingestion. Mapping rule must exist before resource is created. */ mappingRuleName?: pulumi.Input; /** * The name of the Kusto EventHub Data Connection to create. Changing this forces a new resource to be created. */ name?: pulumi.Input; /** * Specifies the Resource Group where the Kusto Database should exist. Changing this forces a new resource to be created. */ resourceGroupName?: pulumi.Input; /** * Specifies the date after which data should be retrieved from Event Hub. When defined, the data connection retrieves existing events created since the specified retrieval start date. It can only retrieve events retained by the Event Hub, based on its retention period. The value should be in RFC3339 format (e.g., `2023-06-26T12:00:00Z`). */ retrievalStartDate?: pulumi.Input; /** * Specifies the target table name used for the message ingestion. Table must exist before resource is created. */ tableName?: pulumi.Input; } /** * The set of arguments for constructing a EventhubDataConnection resource. */ export interface EventhubDataConnectionArgs { /** * Specifies the name of the Kusto Cluster this data connection will be added to. Changing this forces a new resource to be created. */ clusterName: pulumi.Input; /** * Specifies compression type for the connection. Allowed values: `GZip` and `None`. Defaults to `None`. Changing this forces a new resource to be created. */ compression?: pulumi.Input; /** * Specifies the EventHub consumer group this data connection will use for ingestion. Changing this forces a new resource to be created. */ consumerGroup: pulumi.Input; /** * Specifies the data format of the EventHub messages. Allowed values: `APACHEAVRO`, `AVRO`, `CSV`, `JSON`, `MULTIJSON`, `ORC`, `PARQUET`, `PSV`, `RAW`, `SCSV`, `SINGLEJSON`, `SOHSV`, `TSVE`, `TSV`, `TXT`, and `W3CLOGFILE`. */ dataFormat?: pulumi.Input; /** * Specifies the name of the Kusto Database this data connection will be added to. Changing this forces a new resource to be created. */ databaseName: pulumi.Input; /** * Indication for database routing information from the data connection, by default only database routing information is allowed. Allowed values: `Single`, `Multi`. Changing this forces a new resource to be created. Defaults to `Single`. */ databaseRoutingType?: pulumi.Input; /** * Specifies a list of system properties for the Event Hub. */ eventSystemProperties?: pulumi.Input[]>; /** * Specifies the resource id of the EventHub this data connection will use for ingestion. Changing this forces a new resource to be created. */ eventhubId: pulumi.Input; /** * The resource ID of a managed identity (system or user assigned) to be used to authenticate with event hub. */ identityId?: pulumi.Input; /** * The location where the Kusto Database should be created. Changing this forces a new resource to be created. */ location?: pulumi.Input; /** * Specifies the mapping rule used for the message ingestion. Mapping rule must exist before resource is created. */ mappingRuleName?: pulumi.Input; /** * The name of the Kusto EventHub Data Connection to create. Changing this forces a new resource to be created. */ name?: pulumi.Input; /** * Specifies the Resource Group where the Kusto Database should exist. Changing this forces a new resource to be created. */ resourceGroupName: pulumi.Input; /** * Specifies the date after which data should be retrieved from Event Hub. When defined, the data connection retrieves existing events created since the specified retrieval start date. It can only retrieve events retained by the Event Hub, based on its retention period. The value should be in RFC3339 format (e.g., `2023-06-26T12:00:00Z`). */ retrievalStartDate?: pulumi.Input; /** * Specifies the target table name used for the message ingestion. Table must exist before resource is created. */ tableName?: pulumi.Input; }