kippa-data-utils v1.1.8

Kippa Data Utils

A library for accessing Kippa data utilities like the Cache and Queue.

Cache operations

GET and SET variables using the Data Platform Cache.

const { cacheService } = require('kippa-data-utils');
require('dotenv').config()

console.log('Cache Test')

let cache = new cacheService(process.env.API_TOKEN);

let testData = {a:'apple', b: 'bee'};

console.time('set operation');

cache.session('set', {key : 'test_cache_data', value : testData}).then(() => {

    console.timeEnd('set operation');
    console.time('get operation');

    cache.session('get', {key : 'test_cache_data'}).then((data) => {

        console.log('data match ?', data.toString() === testData.toString());
        console.timeEnd('get operation');

    });
});

Queue operations

Enqueue SQL operations on the JPN

const { jpnScheduler } = require('kippa-data-utils');
require('dotenv').config()

console.log('Queue Test')

let queue = new jpnScheduler(process.env.JPN_ACCESS_CODE);

let sqlQuery = 'SELECT COUNT(DISTINCT(b.id)) FROM transaction t inner join business b on t.business = b.id';

console.time('queue operation');

queue.enqueue(sqlQuery, 'prod', true, false).then(() => {

    console.timeEnd('queue operation');

});