Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
const { DataFormat, JsonColumnMapping , IngestionMappingType} = require("azure-kusto-ingest").IngestionPropertiesEnums;
const { BlobDescriptor } = require("azure-kusto-ingest").IngestionDescriptors;
const clusterName = null;
const appId = null;
const appKey = null;
const authorityId = null;
const props = new IngestionProps({
database: "Database",
table: "Table",
format: DataFormat.JSON,
ingestionMapping : [
new JsonColumnMapping("TargetColumn1", "$.sourceProp1"),
new JsonColumnMapping("TargetColumn2", "$.sourceProp2"),
new JsonColumnMapping("TargetColumn3", "$.sourceProp3")
],
ingestionMappingType: IngestionMappingType.JSON,
reportLevel: ReportLevel.FailuresAndSuccesses,
reportMethod: ReportMethod.Queue
});
const ingestClient = new IngestClient(
KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(
`https://ingest-${clusterName}.kusto.windows.net`, appId, appKey, authorityId
),
props
);
const statusQueues = new IngestStatusQueues(ingestClient);
const KustoConnectionStringBuilder = require("azure-kusto-data").KustoConnectionStringBuilder;
const { DataFormat, JsonColumnMapping , IngestionMappingType} = require("azure-kusto-ingest").IngestionPropertiesEnums;
const { BlobDescriptor } = require("azure-kusto-ingest").IngestionDescriptors;
const clusterName = null;
const appId = null;
const appKey = null;
const authorityId = null;
const props = new IngestionProps({
database: "Database",
table: "Table",
format: DataFormat.JSON,
ingestionMapping : [
new JsonColumnMapping("TargetColumn1", "$.sourceProp1"),
new JsonColumnMapping("TargetColumn2", "$.sourceProp2"),
new JsonColumnMapping("TargetColumn3", "$.sourceProp3")
],
ingestionMappingType: IngestionMappingType.JSON,
reportLevel: ReportLevel.FailuresAndSuccesses,
reportMethod: ReportMethod.Queue
});
const ingestClient = new IngestClient(
KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(
`https://ingest-${clusterName}.kusto.windows.net`, appId, appKey, authorityId
),
props
);
const statusQueues = new IngestStatusQueues(ingestClient);
const { ReportLevel, ReportMethod } = require("azure-kusto-ingest").IngestionPropertiesEnums;
const KustoConnectionStringBuilder = require("azure-kusto-data").KustoConnectionStringBuilder;
const { DataFormat, JsonColumnMapping , IngestionMappingType} = require("azure-kusto-ingest").IngestionPropertiesEnums;
const { BlobDescriptor } = require("azure-kusto-ingest").IngestionDescriptors;
const clusterName = null;
const appId = null;
const appKey = null;
const authorityId = null;
const props = new IngestionProps({
database: "Database",
table: "Table",
format: DataFormat.JSON,
ingestionMapping : [
new JsonColumnMapping("TargetColumn1", "$.sourceProp1"),
new JsonColumnMapping("TargetColumn2", "$.sourceProp2"),
new JsonColumnMapping("TargetColumn3", "$.sourceProp3")
],
ingestionMappingType: IngestionMappingType.JSON,
reportLevel: ReportLevel.FailuresAndSuccesses,
reportMethod: ReportMethod.Queue
});
const ingestClient = new IngestClient(
KustoConnectionStringBuilder.withAadApplicationKeyAuthentication(
`https://ingest-${clusterName}.kusto.windows.net`, appId, appKey, authorityId
),
props
);