async executeStreamingIngest()

in packages/azure-kusto-data/src/client.ts [112:137]

• 23 lines of code
• 5 McCabe index (conditional complexity)

    async executeStreamingIngest(
        db: string | null,
        table: string,
        stream: any,
        streamFormat: any,
        mappingName: string | null,
        blob?: string,
        clientRequestId?: string,
    ): Promise<KustoResponseDataSet> {
        let endpoint = `${this.endpoints[ExecutionType.Ingest]}/${this.getDb(db)}/${table}?streamFormat=${streamFormat}`;
        if (mappingName != null) {
            endpoint += `&mappingName=${mappingName}`;
        }

        if (blob) {
            endpoint += `&sourceKind=uri`;
        }

        let properties: ClientRequestProperties | null = null;
        if (clientRequestId) {
            properties = new ClientRequestProperties();
            properties.clientRequestId = clientRequestId;
        }

        return this._execute(endpoint, ExecutionType.Ingest, db, blob ? { blob } : { stream }, properties);
    }