Use kdb Insights Enterprise Language Interfaces

This page provides an example which demonstrates how to deploy the kxi-db package, publish data to it, and query the data through secure, authenticated endpoints within kdb Insights Enterprise.

The goal is to deploy the package to the kdb Insights Enterprise base application to enable data ingestion, persistence, and querying.

Deploying the package

Deploy the package on top of the base instance of the kdb Insights Enterprise in your cluster.

To deploy the package, download the kxi-db-1.0.0.kxi from the release repository and deploy it to your cluster using the following command:

shell

Copy
kxi pm push kxi-db-1.0.0.kxi
kxi pm deploy kxi-db

Client integration

After deployment, kdb Insights Enterprise and kxi-db are ready to ingest data.

A client must be enrolled to allow data to be published through the authenticated and secure RT entry-point. Clients can be either users or service accounts. Users and service accounts are created in Keycloak. For more information, refer to the Keycloak documentation.

The diagram below highlights the key components that allow the flow of data into the system from external sources. To do this securely it's necessary to utilize the Information Service and the Client Controller to register clients and to allow them to understand the endpoints. It must also authorize itself and publish the data to the appropriate location.

 

Client Registration

Client enrollment

Prerequisite

A service account or user account must be created in Keycloak and assigned the necessary roles. Your system administrator can set up the user or service account.

Information

Keycloak roles

Here is more information on the relevant Keycloak roles. To enroll a client to publish data to an RT stream, the insights.client.create and insights.client.delete roles are necessary for the user or service account.

Authenticating as a user

Your system administrator can use the below commands to create a user:

bash

Copy
kxi user create demouser --password demoUserPassword --admin-password myAdminPassword
INSIGHTS_ROLES="insights.client.create,insights.client.delete"
kxi user assign-roles demouser --roles $INSIGHTS_ROLES --admin-password myAdminPassword

This user can now authenticate with the KXI CLI.

bash

Copy
kxi auth login # This command launches the browser where demouser can authenticate

Authenticating as service account

Your system administrator can use the below commands to create a service account:

bash

Copy
CLIENT_ID=svc1
INSIGHTS_ROLES="insights.client.create,insights.client.delete"
kxi user create-client $CLIENT_ID --admin-password myAdminPassword
kxi user assign-roles service-account-$CLIENT_ID --roles $INSIGHTS_ROLES --admin-password myAdminPassword
CLIENT_SECRET=$(kxi user get-client-secret $CLIENT_ID --admin-password myAdminPassword)

The admin can provide the above CLIENT_ID and CLIENT_SECRET to any user for configuring their KXI CLI using the below commands.

Information

Service account ID and secret

Your $CLIENT_ID and $CLIENT_SECRET should be inputted to the 'Service account ID' and 'Service account Secret' fields.

bash

Copy
kxi configure
Profile type (enterprise, microservices) [enterprise]:
Hostname []: https://{INSIGHTS_HOSTNAME}/
Namespace []: namespace
Service account ID []: 
Service account Secret (input hidden):
Re-enter to confirm (input hidden):
Encryption enabled (true/false) [true]:
CLI successfully configured, configuration stored in /home/username/.insights/cli-config

After configuring the kxi with the service account credentials, any user can authenticate as a service account

bash

Copy
kxi auth login --serviceaccount

For further details on authentication, refer to the Authentication documentation.

Enroll

Users who want to publish or subscribe to a RT stream from outside of their kdb Insights Enterprise cluster must enroll in order to obtain endpoints to connect to. Details on how you can enroll as a publisher or subscriber are provided below.

External Reference ID

As part of the enrollment step an external reference ID must be provided.

In this example, using the kxi-db package, the external reference ID is ext-mystream.

From the kxi-db package.

shell

Copy
sequencers:
  mystream:
    external: true
    ...
    topicConfig:
      subTopic: ext-mystream
      extSubStream: ext-sub-mystream

Note

External Reference IDs

The reference ID can be identified from one of two places:

  • When using the kxi pm command to define a package, you can find the reference ID under the subTopic field in the sequencers section of the kxi-db/databases/mydb/shards/mydb-shard.yaml file.

  • For web interface deployments, locate the reference ID under the Database's Stream Settings tab. The external reference is displayed in the External data ingress setting. In the example below, the reference ID is mystream-ingr.

External stream in the UI

Publish

  1. Enroll the client using the external reference ID.

    shell

    Copy
    kxi client enrol --name publisherName --insert-topic ext-mystream
    ```shell-session
    {
      "message": "success",
      "detail": "Client enrolled",
      "url": "5ed6e5b7c80c8e35d07249d12f32d9eb",
      "config_url": "https://{INSIGHTS_HOSTNAME}/informationservice/details/5ed6e5b7c80c8e35d07249d12f32d9eb"
    }

The config_url field must be stored as it's used by the publisher to get publish endpoints. The config_url is unique to the publisherName above.

Subscribe

Enroll the client using the external reference ID.

shell

Copy
kxi client enrol --name subscriberName --subscribe ext-sub-mystream

```shell-session
{
  "message": "success",
  "detail": "Client enrolled",
  "url": "5ed6e5b7c80c8e35d07249d12f32d9eb",
  "config_url": "https://{INSIGHTS_HOSTNAME}/informationservice/details/5ed6e5b7c80c8e35d07249d12f32d9eb"
}

The config_urlfield must be stored as it is used by the subscriber to get subscription endpoints. This is unique to the subscriberName above.

Removing a client

Authentication with the CLI is a pre-requisite for this step, as described here.

A client can be removed by running the CLI command below:

shell

Copy
kxi client remove --name publisherName

shell

Copy
{
  "message": "success",
  "detail": "Client removed"
}