Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
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);
function waitForFailures() {
statusQueues.failure.isEmpty((err, empty) => {
if (err) throw new Error(err);
if (empty) {
console.log("no errors...");
return setTimeout(waitForFailures, 1000);
}
else {
statusQueues.failure.pop((err, failures) => {
if (err) throw new Error(err);
for (let failure of failures) {
console.log(JSON.stringify(failure));
}