Event
data class EventGridDataConnectionArgs(val blobStorageEventType: Output<String>? = null, val clusterName: Output<String>? = null, val dataFormat: Output<String>? = null, val databaseName: Output<String>? = null, val databaseRoutingType: Output<String>? = null, val eventgridResourceId: Output<String>? = null, val eventhubConsumerGroupName: Output<String>? = null, val eventhubId: Output<String>? = null, val location: Output<String>? = null, val managedIdentityResourceId: Output<String>? = null, val mappingRuleName: Output<String>? = null, val name: Output<String>? = null, val resourceGroupName: Output<String>? = null, val skipFirstRecord: Output<Boolean>? = null, val storageAccountId: Output<String>? = null, val tableName: Output<String>? = null) : ConvertibleToJava<EventGridDataConnectionArgs>
Manages a Kusto (also known as Azure Data Explorer) Event Grid Data Connection
Example Usage
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.kusto.Cluster;
import com.pulumi.azure.kusto.ClusterArgs;
import com.pulumi.azure.kusto.inputs.ClusterSkuArgs;
import com.pulumi.azure.kusto.Database;
import com.pulumi.azure.kusto.DatabaseArgs;
import com.pulumi.azure.storage.Account;
import com.pulumi.azure.storage.AccountArgs;
import com.pulumi.azure.eventhub.EventHubNamespace;
import com.pulumi.azure.eventhub.EventHubNamespaceArgs;
import com.pulumi.azure.eventhub.EventHub;
import com.pulumi.azure.eventhub.EventHubArgs;
import com.pulumi.azure.eventhub.ConsumerGroup;
import com.pulumi.azure.eventhub.ConsumerGroupArgs;
import com.pulumi.azure.eventgrid.EventSubscription;
import com.pulumi.azure.eventgrid.EventSubscriptionArgs;
import com.pulumi.azure.eventgrid.inputs.EventSubscriptionRetryPolicyArgs;
import com.pulumi.azure.kusto.EventGridDataConnection;
import com.pulumi.azure.kusto.EventGridDataConnectionArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var example = new ResourceGroup("example", ResourceGroupArgs.builder()
.name("example-resources")
.location("West Europe")
.build());
var exampleCluster = new Cluster("exampleCluster", ClusterArgs.builder()
.name("examplekustocluster")
.location(example.location())
.resourceGroupName(example.name())
.sku(ClusterSkuArgs.builder()
.name("Standard_D13_v2")
.capacity(2)
.build())
.build());
var exampleDatabase = new Database("exampleDatabase", DatabaseArgs.builder()
.name("example-kusto-database")
.resourceGroupName(example.name())
.location(example.location())
.clusterName(exampleCluster.name())
.hotCachePeriod("P7D")
.softDeletePeriod("P31D")
.build());
var exampleAccount = new Account("exampleAccount", AccountArgs.builder()
.name("storageaccountname")
.resourceGroupName(example.name())
.location(example.location())
.accountTier("Standard")
.accountReplicationType("GRS")
.build());
var exampleEventHubNamespace = new EventHubNamespace("exampleEventHubNamespace", EventHubNamespaceArgs.builder()
.name("eventhubnamespace-example")
.location(example.location())
.resourceGroupName(example.name())
.sku("Standard")
.build());
var exampleEventHub = new EventHub("exampleEventHub", EventHubArgs.builder()
.name("eventhub-example")
.namespaceName(exampleEventHubNamespace.name())
.resourceGroupName(example.name())
.partitionCount(1)
.messageRetention(1)
.build());
var exampleConsumerGroup = new ConsumerGroup("exampleConsumerGroup", ConsumerGroupArgs.builder()
.name("consumergroup-example")
.namespaceName(exampleEventHubNamespace.name())
.eventhubName(exampleEventHub.name())
.resourceGroupName(example.name())
.build());
var exampleEventSubscription = new EventSubscription("exampleEventSubscription", EventSubscriptionArgs.builder()
.name("eventgrid-example")
.scope(exampleAccount.id())
.eventhubEndpointId(exampleEventHub.id())
.eventDeliverySchema("EventGridSchema")
.includedEventTypes(
"Microsoft.Storage.BlobCreated",
"Microsoft.Storage.BlobRenamed")
.retryPolicy(EventSubscriptionRetryPolicyArgs.builder()
.eventTimeToLive(144)
.maxDeliveryAttempts(10)
.build())
.build());
var exampleEventGridDataConnection = new EventGridDataConnection("exampleEventGridDataConnection", EventGridDataConnectionArgs.builder()
.name("my-kusto-eventgrid-data-connection")
.resourceGroupName(example.name())
.location(example.location())
.clusterName(exampleCluster.name())
.databaseName(exampleDatabase.name())
.storageAccountId(exampleAccount.id())
.eventhubId(exampleEventHub.id())
.eventhubConsumerGroupName(exampleConsumerGroup.name())
.tableName("my-table")
.mappingRuleName("my-table-mapping")
.dataFormat("JSON")
.build());
}
}Content copied to clipboard
Import
Kusto Event Grid Data Connections can be imported using the resource id, e.g.
$ pulumi import azure:kusto/eventGridDataConnection:EventGridDataConnection example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.Kusto/clusters/cluster1/databases/database1/dataConnections/dataConnection1Content copied to clipboard
Constructors
Link copied to clipboard
fun EventGridDataConnectionArgs(blobStorageEventType: Output<String>? = null, clusterName: Output<String>? = null, dataFormat: Output<String>? = null, databaseName: Output<String>? = null, databaseRoutingType: Output<String>? = null, eventgridResourceId: Output<String>? = null, eventhubConsumerGroupName: Output<String>? = null, eventhubId: Output<String>? = null, location: Output<String>? = null, managedIdentityResourceId: Output<String>? = null, mappingRuleName: Output<String>? = null, name: Output<String>? = null, resourceGroupName: Output<String>? = null, skipFirstRecord: Output<Boolean>? = null, storageAccountId: Output<String>? = null, tableName: Output<String>? = null)