Use the Accelerators

The page describes example access methods using pre-built components in the Accelerators.

While the specific use case of each accelerator may be different, there are shared common methods of usage. Any method of data access within the Insights Enterprise platform is valid.

For detailed API information, refer to the API documentation.

Request-reply query

Methods for using the in-built get* APIs.

qIPC

Connect to the service gateway and issue a qIPC query.

Tip

The gw variable below is defined as an IPC connection to the Service Gateway. For example :insights-qe-gateway:5050 would connect to the query environment gateway within an insights namespace.

q

Copy 
// API arguments dictionary.
args: (!) . flip (
    (`table;            `Trade);
    (`startTS;          2000.01.01D00:00:00);
    (`endTS;            2000.01.02D00:00:00)
    );

//Options dictionary in the query (none)
opts:()!()

//issue query to gw handle
gw(`getTicks;args;`callback;opts)

REST

Refer to Insights Enterprise documentation on query using REST

An example of basic REST call using curl would be:

Shell

Copy 
export INSIGHTS_TOKEN=$(curl --header "Content-Type: application/x-www-form-urlencoded" -d "grant_type=client_credentials&client_id=$INSIGHTS_CLIENT_ID&client_secret=$INSIGHTS_CLIENT_SECRET" "${INSIGHTS_URL}/auth/realms/insights/protocol/openid-connect/token" | jq -r '.access_token');

and then make the REST call using the custom API .client.testAPI:

Shell

Copy 
curl -X POST "${INSIGHTS_URL}/servicegateway/client/testAPI" \
        -H "Content-Type: application/json" \
        -H "Accepted: application/json" \
        -H "Authorization: Bearer $INSIGHTS_TOKEN" \
        --data "$(jq -n \
        '{
                table   : "Trade",
                startTS : "2000.01.01D00:00:00.000000000",
                endTS   : "2000.01.02D00:00:00.000000000"
        }' | jq -cr .)"

Dashboard views

Build a dashboard using the in built-APIs.

For information about dashboard views, refer to the Insights Enterprise docs.

All of the Accelerator APIs are available in a query under fsi as seen below.

Real-time connectivity

By customizing a stream processor pipeline, the output of any ingest and transform can be republished to another service, like Kafka.

Refer to Insights Enterprise docs on pipeline writers for details.