Microsoft Azure Kusto Ingest Library for JavaScript

Installation

npm install azure-kusto-ingest

Quick Start

``javascript
const IngestClient = require("azure-kusto-ingest").IngestClient;
const IngestionProps = require("azure-kusto-ingest").IngestionProperties;
const KustoConnectionStringBuilder = require("azure-kusto-data").KustoConnectionStringBuilder;
const {DataFormat, JsonColumnMapping} = require("azure-kusto-ingest");

const kcsb = KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(https://ingest-${cluster}.kusto.windows.net, appId, appKey, authorityId);

const ingestionProps = new IngestionProps({
database: "Database",
table: "Table",
format: DataFormat.JSON,
ingestionMapping: [
JsonColumnMapping.withPath("TargetColumn1", "$.sourceProp1"),
JsonColumnMapping.withPath("TargetColumn2", "$.sourceProp2"),
JsonColumnMapping.withPath("TargetColumn3", "$.sourceProp3"),
],
});

const ingestClient = new IngestClient(kcsb, ingestionProps);

console.log("Ingest from file");

Ingest();

async function Ingest() {
try {
await ingestClient.ingestFromFile("file.json", null);
} catch (err) {
console.log(err);
}
console.log("Wait for ingestion status...");
await waitForStatus();
}
`

Authentication

There are several authentication methods

$3

The are two ways to authenticate is to use app id and key

1. Using app key

`javascript
const kcsb = KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(
https://ingest-${clusterName}.kusto.windows.net,
"appid",
"appkey",
"authorityId"
);
`

1. Using a certificate:

`javascript
const kcsb = KustoConnectionStringBuilder.withAadApplicationCertificateAuthentication(
https://ingest-${clusterName}.kusto.windows.net,
"appid",
"certificate",
"authorityId"
);
`

$3

`javascript
KustoConnectionStringBuilder.withAadUserPasswordAuthentication(https://${clusterName}.kusto.windows.net, "username", "password");
`

Authority is optional _when it can be inferred from the domain_ ('user@microsoft.com' would make the authority 'microsoft.com').
In any case it is possible to pass the authority id

`javascript
KustoConnectionStringBuilder.withAadUserPasswordAuthentication(https://ingest-${clusterName}.kusto.windows.net, "username", "password", "authorityId");
`

$3

Using this method will write a token to the console, which can be used to authenticate at https://login.microsoftonline.com/common/oauth2/deviceauth and will allow temporary access.

It is not ment for production purposes

`javascript
// will log the DEVICE token and url to use
KustoConnectionStringBuilder.withAadDeviceAuthentication(https://${clusterName}.kusto.windows.net, authId);

// in case you want to do your own thing with the response, you can pass a callback
// NOTICE: code will still block until device is authenticated
KustoConnectionStringBuilder.withAadDeviceAuthentication(https://${clusterName}.kusto.windows.net, authId, (tokenResponse) => {
// your code, for example copy to clipboard or open url in browser
console.log("Open " + tokenResponse.verificationUrl + " and use " + tokenResponse.userCode + " code to authorize.");
});
`

Usage

A Quick Overview is available at https://docs.microsoft.com/en-us/azure/data-explorer/ingest-data-overview

Notice ingestion is done against the ingestion endpoint, which usually include ingest- prefix on the cluster name.

$3

Ingestion Props are instructions for Kusto on how to process the data.

The easiest way to provide ingestion properties is to set them on the ingestion client like in the sample above.
It is also possible to pass them on each ingestion (will merge them with default props).

Example props:

`javascript
const ingestionProps = new IngestionProps("Database", "Table", DataFormat.JSON, [
JsonColumnMapping.withPath("TargetColumn1", "$.sourceProp1"),
JsonColumnMapping.withPath("TargetColumn2", "$.sourceProp2"),
JsonColumnMapping.withPath("TargetColumn3", "$.sourceProp3"),
]);
`

$3

There are several methods of ingesting data into Kusto (Azure Data Explorer) using this library

#### From Stream

This is useful for cases you already have streams available (http respinse, file stream, etc..)

``javascript
try{
await ingestClient.ingestFromStream(readable, null);
}
catch(err){
console.log(err);
}
console.log("Ingestion from stream DONE");
``

#### From File

Ingesting a file first makes sure it's zipped (if not, it zips it locally) and then send it for ingestion

`javascript
let blob = new BlobDescriptor(blobUri, size);
try{
await ingestClient.ingestFromFile("file.json", null);
}
catch(err){
console.log(err);
}
``

#### From Azure Storage Blob

Probably the easiest way would be to provide a uri (with SAS).

`javascript
let blob = new BlobDescriptor(blobUri, size);
try {
await ingestClient.ingestFromBlob(blob, null);
} catch (err) {
console.log(err);
}
`

$3

It is possible to track the status of the ingestion using status queues.

Enabling is done simply but setting the reportLevel Ingestion Property to ReportLevel.FailuresAndSuccesses

For Example:

`javascript
const IngestClient = require('azure-kusto-ingest').IngestClient;
const IngestStatusQueues = require('azure-kusto-ingest').IngestStatusQueues;
const IngestionProps = require('azure-kusto-ingest').IngestionProperties;
const {ReportLevel, ReportMethod} = require('azure-kusto-ingest');
const KustoConnectionStringBuilder = require('azure-kusto-data').KustoConnectionStringBuilder;
const {DataFormat, JsonColumnMapping} = require('azure-kusto-ingest');
const fs = require('fs');

const ingestClient = new IngestClient(
KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(https://ingest-${clusterName}.kusto.windows.net, appId, appKey, authorityId),
new IngestionProps({
database: 'Database',
table: 'Table',
format: DataFormat.JSON,
ingestionMapping: [
JsonColumnMapping.withPath('TargetColumn1', '$.sourceProp1'),
JsonColumnMapping.withPath('TargetColumn2', '$.sourceProp2'),
JsonColumnMapping.withPath('TargetColumn3', '$.sourceProp3'),
],
ingestionMappingType: IngestionMappingKind.JSON,
reportLevel: ReportLevel.FailuresAndSuccesses,
reportMethod: ReportMethod.Queue,
})
);

const statusQueues = new IngestStatusQueues(ingestClient);

async function waitForStatus() {
while ((await statusQueues.failure.isEmpty()) && (await statusQueues.success.isEmpty())) {
await new Promise((resolve) => {
setTimeout(resolve, 1000);
});
}

const successes = statusQueues.success.pop();
for (let success of successes) {
console.log(JSON.stringify(success));
}

const failures = statusQueues.failure.pop();
for (let failure of failures) {
console.log(JSON.stringify(failure));
}
}

async function ingestFromFile() {
try {
await ingestClient.ingestFromFile('file.json', null);
} catch (err) {
console.log(err);
}
console.log('Wait for ingestion status...');
await waitForStatus();
}
`

#### From Browser Blob object

A full browser example can be found here

`javascript
const file = new Blob([{"Name":"Moshe", "Value":2}], { type: "application/json" });
let desc = new FileDescriptor(blobUri, size);
try {
await ingestClient.ingestFromFile(desp, null);
} catch (err) {
console.log(err);
}
``