Connecting to StarTree Cloud via Node.js
Applications can use this sample client Node.js driver to query Pinot.
Caution: This solution may not scale to meet performance and throughput requirements for your use case.
Integrate Pinot in Node.js applications
- Install axios.
npm install axios- Contact StarTree Support to obtain the following information:
- Controller URL: The general format is
https://pinot.<random-string>.cp.s7e.startree.cloud - Broker URL: The general format is
https://pinot.<random-string>.cp.s7e.startree.cloud - AUTH_TOKEN
- Run the Node.js driver script:
node queryPinot.jsqueryPinot.js: Node.js driver script
const axios = require('axios');
// Pinot broker and controller URLs
const pinotBrokerUrl = '<Broker URL mentioned above>';
const pinotControllerUrl = '<Controller URL mentioned above>';
// Function to query Pinot broker
async function queryPinotBroker() {
try {
const response = await axios.post(`${pinotBrokerUrl}/query/sql`, {
// Add your SQL query here
sql: 'SELECT count(*) FROM <TABLE_NAME>,
}, {
headers: {
Authorization: 'Basic <AUTH_TOKEN>',
}
});
console.log('Query Result:', response.data);
} catch (error) {
console.error('Error querying Pinot broker:', error.message);
}
}
// Function to fetch Pinot table schema from controller
async function getPinotTableSchema(tableName) {
try {
const response = await axios.get(`${pinotControllerUrl}/tables/${tableName}/schema`, {
headers: {
Authorization: 'Basic <AUTH_TOKEN>',
}
});
console.log('Table Schema:', response.data);
} catch (error) {
console.error('Error fetching table schema:', error.message);
}
}
// Example usage
queryPinotBroker();
getPinotTableSchema('companies_v1');