Loading a CSV with Qlik Core

load.js

const { connectSession } = require("rxq");
const { concat } = require("rxjs");
const { switchMap, shareReplay, take, tap } = require("rxjs/operators");

const config = {
  host: "localhost",
  port: 19076
};

// Engine Session
const session = connectSession(config);

// Create and open doc
const doc$ = session.global$.pipe(
  switchMap(h =>
    h
      .ask("CreateApp", "RussianTweets.qvf")
      .pipe(switchMap(() => h.ask("OpenDoc", "RussianTweets.qvf")))
  ),
  shareReplay(1)
);

// Create connection
const createConnection$ = doc$.pipe(
  switchMap(h =>
    h.ask("CreateConnection", {
      qName: "data",
      qConnectionString: "/data",
      qType: "folder"
    })
  ),
  take(1)
);

// Create load script
const script = `
Load *
FROM [lib://data/IRA_tweets_combined.csv]
(txt, utf8, embedded labels, delimiter is ',');
`;

const setScript$ = doc$.pipe(
  switchMap(h => h.ask("SetScript", script)),
  take(1)
);

let startTime;

// Do reload
const doReload$ = doc$.pipe(
  tap(() => {
    console.log("started reload");
    startTime = Date.now();
  }),
  switchMap(h => h.ask("DoReload")),
  tap(() => console.log("reloaded")),
  tap(() => {
    console.log(Date.now() - startTime);
  }),
  take(1)
);

// Do save
const doSave$ = doc$.pipe(
  switchMap(h => h.ask("DoSave")),
  tap(() => console.log("saved")),
  take(1)
);

// Execute the chain
concat(createConnection$, setScript$, doReload$, doSave$).subscribe(
  () => {},
  err => console.log(err)
);