Microsoft.Azure.WebJobs.Extensions.Kusto 1.0.11-Preview

Prefix Reserved
This is a prerelease version of Microsoft.Azure.WebJobs.Extensions.Kusto.
dotnet add package Microsoft.Azure.WebJobs.Extensions.Kusto --version 1.0.11-Preview                
NuGet\Install-Package Microsoft.Azure.WebJobs.Extensions.Kusto -Version 1.0.11-Preview                
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Microsoft.Azure.WebJobs.Extensions.Kusto" Version="1.0.11-Preview" />                
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Microsoft.Azure.WebJobs.Extensions.Kusto --version 1.0.11-Preview                
#r "nuget: Microsoft.Azure.WebJobs.Extensions.Kusto, 1.0.11-Preview"                
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install Microsoft.Azure.WebJobs.Extensions.Kusto as a Cake Addin
#addin nuget:?package=Microsoft.Azure.WebJobs.Extensions.Kusto&version=1.0.11-Preview&prerelease

// Install Microsoft.Azure.WebJobs.Extensions.Kusto as a Cake Tool
#tool nuget:?package=Microsoft.Azure.WebJobs.Extensions.Kusto&version=1.0.11-Preview&prerelease                

Kusto bindings for Azure Functions - Preview

Table of Contents

Introduction

This repository contains the Kusto bindings for Azure Functions extension code as well as a quick start tutorial and samples illustrating how to use the binding in different ways. The types of bindings supported are:

Input Binding

Takes a KQL query or KQL function to run (with optional parameters) and returns the output to the function. The input binding takes the following attributes

  • Database: The database against which the query has to be executed

  • ManagedServiceIdentity: A managed identity can be used to connect to Kusto. To use a System managed identity, use "system", any other identity names are interpreted as user managed identity

  • KqlCommand: The KqlQuery that has to be executed. Can be a KQL query or a KQL Function call

  • KqlParameters: Parameters that act as predicate variables for the KqlCommand. For example "@name={name},@Id={id}" where the parameters {name} and {id} will be substituted at runtime with actual values acting as predicates

  • Connection: The name of the variable that holds the connection string, resolved through environment variables or through function app settings. Defaults to lookup on the variable KustoConnectionString, at runtime this variable will be looked up against the environment. Documentation on connection string can be found at Kusto connection strings e.g.: "KustoConnectionString": "Data Source=https://_**cluster**_.kusto.windows.net;Database=_**Database**_;Fed=True;AppClientId=_**AppId**_;AppKey=_**AppKey**_;Authority Id=_**TenantId**_ Note that the application id should atleast have viewer privileges on the table(s)/function(s) being queried in the KqlCommand

  • ClientRequestProperties: Optional attribute to pass client request properties to the Kusto client

Starting versions 1.0.8-Preview there is support for management commands. A sample is available here

Output Binding

Takes row(s) and inserts them into the Kusto table .

  • Database: The database against which the query has to be executed

  • TableName: The table to ingest the data into

  • ManagedServiceIdentity: A managed identity can be used to connect to Kusto. To use a System managed identity, use "system", any other identity names are interpreted as user managed identity

  • Connection: Refer Connection attribute above.Note that the application id should have ingest privileges on the table being ingested into

  • MappingRef: Optional attribute to pass a mapping ref that is already defined in the ADX cluster

  • DataFormat: The default dataformat is multijson/json. This can be set to text formats supported in the datasource format enumeration. Samples are validated and provided for csv and JSON formats.

  • IngestionType: Optional attribute to different ingestion types. Supported values are queued ingestion or managed ingestion which attempts streaming ingest falling back to queued ingestion. The default value is managed

  • IngestionProperties: Optional attribute pertinent to queued ingestion type. When using queued ingestion, the following values can be specified

    • flushImmediately: Whether aggregation has to be performed during ingestion

    • pollIntervalSeconds: Queued ingestion is an async operation. Indicates how often to poll for a result to report status of ingestion. Defaults to 15 seconds

    • pollTimeoutMinutes: Timeout to report failure of queued ingestion. Defaults to 5 minutes

      This is specified as @flushImmediately=false,@pollIntervalSeconds=15,@pollTimeoutMinutes=5 like other kusto binding properties.

Samples

Samples for C# are available and available at the following. This can run with local functions framework. Setup required for the run is available at the location

Known Issues

Trademarks

This project may contain trademarks or logos for projects, products, or services. Authorized use of Microsoft trademarks or logos is subject to and must follow Microsoft’s Trademark & Brand Guidelines. Use of Microsoft trademarks or logos in modified versions of this project must not cause confusion or imply Microsoft sponsorship. Any use of third-party trademarks or logos are subject to those third-party’s policies.

Product Compatible and additional computed target framework versions.
.NET net5.0 was computed.  net5.0-windows was computed.  net6.0 was computed.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
.NET Core netcoreapp3.0 was computed.  netcoreapp3.1 was computed. 
.NET Standard netstandard2.1 is compatible. 
MonoAndroid monoandroid was computed. 
MonoMac monomac was computed. 
MonoTouch monotouch was computed. 
Tizen tizen60 was computed. 
Xamarin.iOS xamarinios was computed. 
Xamarin.Mac xamarinmac was computed. 
Xamarin.TVOS xamarintvos was computed. 
Xamarin.WatchOS xamarinwatchos was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
1.0.11-Preview 974 9/5/2024
1.0.10-Preview 179 7/1/2024
1.0.9-Preview 4,046 11/9/2023
1.0.8-Preview 545 8/28/2023
1.0.7-Preview 1,263 4/24/2023
1.0.6-Preview 133 4/19/2023
1.0.5-Preview 146 4/11/2023
1.0.4-Preview 117 3/1/2023
1.0.3-Preview 114 2/22/2023
1.0.2-Preview 112 2/14/2023
1.0.1-Preview 109 2/6/2023
1.0.0-Preview 208 1/25/2023