Connect with the Node.js driver
|
DataStax recommends the Data API and clients for Serverless (vector) databases. You can use the Data API to run CQL statements on tables in Serverless (vector) databases. DataStax recommends drivers only for Serverless (non-vector) databases, legacy applications that rely on a driver, or CQL functions that aren’t supported by the Data API. For more information, see Connect to Astra DB Serverless databases. |
Because Astra DB is based on Apache Cassandra®, you can use Cassandra drivers to connect to your Astra DB Serverless databases.
To use the Node.js driver, you need to install the driver and its dependencies, and then connect the driver to your database. Once connected, you can write scripts that use the driver to run commands against your database.
This quickstart explains how to use the Node.js driver to connect to an Astra DB Serverless database and send some Cassandra Query Language (CQL) statements to the database. It also explains how to upgrade from an earlier version of the Node.js driver to a version that supports Astra DB.
Prerequisites
-
Install Node.js LTS version with
npm. -
Download your database’s Secure Connect Bundle (SCB).
For multi-region databases, download the SCB for a region that is geographically close to your application to reduce latency.
If you need to connect to multiple regions in the same application, you need the SCB for each region, and your driver code must instantiate one root object (
session) for each region. For more information, see Best practices for Cassandra drivers. -
Set the following environment variables:
-
DATABASE_ID: The database ID. -
APPLICATION_TOKEN: An application token with the Database Administrator role.
-
Driver authentication methods
There are two driver authentication methods:
tokenauthentication-
The
tokenauthentication method is supported and recommended for most recent driver versions.In your driver authentication code, pass the literal string
tokenas the username and your application token value (AstraCS:…) as the password. For example:("token", "AstraCS:...") clientIdandsecretauthentication-
If you are on an older driver version that doesn’t support
tokenauthentication, then you might need to useclientIdandsecret.When you generate an application token, download or copy the
token.jsonthat contains the following values:{ "clientId": "CLIENT_ID", "secret": "CLIENT_SECRET", "token": "APPLICATION_TOKEN" }Then, in your driver authentication code, pass
clientIdas the username andsecretas the password. For example:("CLIENT_ID", "SECRET")
For more information, see Token details.
Install the Node.js driver
-
Install the Node.js driver:
npm install cassandra-driverIf you install an earlier version of the driver, make sure your version is compatible with Astra DB. If you need to query vector data in Astra DB Serverless (vector) databases, make sure your version also supports vector data. For more information, see Cassandra drivers supported by DataStax.
Connect the Node.js driver
-
In the root of your Node.js project, create a
connect-database.jsfile:cd nodejsProject touch connect-database.js -
Copy the following connection code into the
connect-database.jsfile, and then replacePATH/TO/SCB.zipwith the absolute path to your database’s Secure Connect Bundle (SCB) zip file (secure-connect-DATABASE_NAME.zip):connect-database.jsconst cassandra = require('cassandra-driver'); const cloud = { secureConnectBundle: "PATH/TO/SCB.zip" }; const authProvider = new cassandra.auth.PlainTextAuthProvider('token', process.env['APPLICATION_TOKEN']); const client = new cassandra.Client({ cloud, authProvider }); async function run() { await client.connect(); // ... await client.shutdown(); }This code creates a
Clientinstance to connect to your database. Use this instance to run CQL statements against your database, as demonstrated in the next step. -
To test the connection, add a simple query to the script.
The following example queries the
system.localtable. You can replace the exampleSELECTstatement with any CQL statement that you want to run against a keyspace and table in your database.async function run() { await client.connect(); // Execute a query const rs = await client.execute('SELECT * FROM system.local'); console.log(Hello from cluster: ${rs.first()['cluster_name']}); await client.shutdown(); } -
Save and then run
connect-database.jswith the Node.js runtime:node connect-database.jsIf you ran the example
SELECTstatement on thesystem.localtable, then thecluster_namevalue from thesystem.localtable is printed to the console if the script runs successfully.
Run a vector search with the Node.js driver
The following example shows how you can use the Node.js driver to index vector data and then run a vector search:
-
Create a table and vector index.
The following code creates a table named
vector_testwith columns for an integer id, text, and a 5-dimensional vector. Then, it creates a custom index on the vector column using dot product similarity function for efficient vector searches.This example uses a keyspace named
default_keyspace. Replace this value if you want to use a different keyspace.// ... const keyspace = 'default_keyspace'; const v_dimension = 5; await client.execute(` CREATE TABLE IF NOT EXISTS ${keyspace}.vector_test (id INT PRIMARY KEY, text TEXT, vector VECTOR<FLOAT,${v_dimension}>); `); await client.execute(` CREATE CUSTOM INDEX IF NOT EXISTS idx_vector_test ON ${keyspace}.vector_test (vector) USING 'StorageAttachedIndex' WITH OPTIONS = {'similarity_function' : 'cosine'}; `); // ... -
Insert vector data.
The following code inserts some rows with embeddings into the
vector_testtable:// ... const text_blocks = [ { id: 1, text: 'Chat bot integrated sneakers that talk to you', vector: [0.1, 0.15, 0.3, 0.12, 0.05] }, { id: 2, text: 'An AI quilt to help you sleep forever', vector: [0.45, 0.09, 0.01, 0.2, 0.11] }, { id: 3, text: 'A deep learning display that controls your mood', vector: [0.1, 0.05, 0.08, 0.3, 0.6] }, ]; for (let block of text_blocks) { const {id, text, vector} = block; await client.execute( `INSERT INTO ${keyspace}.vector_test (id, text, vector) VALUES (${id}, '${text}', [${vector}])` ); } // ... -
Perform a vector search.
The following code performs a vector search to find rows that are close to a specific vector embedding:
// ... const ann_query = ` SELECT id, text, similarity_cosine(vector, [0.15, 0.1, 0.1, 0.35, 0.55]) as sim FROM ${keyspace}.vector_test ORDER BY vector ANN OF [0.15, 0.1, 0.1, 0.35, 0.55] LIMIT 2 `; const result = await client.execute(ann_query); result.rows.forEach(row => { console.log(`[${row.id}] "${row.text}" (sim: ${row.sim.toFixed(4)})`); }); await client.shutdown(); } run().catch(console.error);
Upgrade the Node.js driver
Use these steps if you need to upgrade from an earlier version of the Node.js driver to a version that supports Astra DB:
-
In your existing DataStax Node.js driver code, modify the connection code to use the SCB and
tokenauthentication.const { Client } = require('cassandra-driver'); const cloud = { secureConnectBundle: "PATH/TO/SCB.zip" }; const authProvider = new cassandra.auth.PlainTextAuthProvider('token', process.env['APPLICATION_TOKEN']); const client = new cassandra.Client({ cloud, authProvider });For more information, see Connect the Node.js driver.
Next steps
You can extend or modify the example script used in this guide to run other commands against your database, or connect to other databases. For more information, see the following: