Create
Jump to the Code block for a combined complete example.
Create a document record
The following command uses the Aerospike Admin (asadm) to create an integer index on the sandbox
namespace, ufodata
set, and occurred
bin. This is the recommended way to create a secondary index.
asadm -e 'enable; manage sindex create numeric occurred_idx ns sandbox set ufodata bin occurred'
Setup
Import the necessary helpers, create a client connection, and create a key.
const Aerospike = await import("aerospike");const exp = Aerospike.exp;
// Set hosts to your server's address and portconst config = { hosts: "YOUR_HOST_ADDRESS:YOUR_PORT" };
// Establishes a connection to the serverconst client = await Aerospike.connect(config);
Create a JSON document
Prepare the JSON document to be sent to Aerospike.
const data = JSON.parse(await readFile("./employees.json", "utf8"));
const bins = { employees: data.employees };
const metadata = null;
Source document:
{ "employees": [ { "id": "09", "name": "Nitin", "department": "Finance" }, { "id": "10", "name": "Jonathan", "department": "Human Resources" }, { "id": "11", "name": "Caitlin", "department": "Engineering" } ]}
Write
Write the document to Aerospike.
await client.put(key, bins, metadata, writePolicy);
Code block
Expand this section for a single code block to create a document record.
import { readFile } from "node:fs/promises";
const Aerospike = await import("aerospike");
// Set hosts to your server's address and portconst config = { hosts: "YOUR_HOST_ADDRESS:YOUR_PORT" };
// Create a keyconst key = new Aerospike.Key("sandbox", "ufodata", 5001);
// Create a new write policyconst writePolicy = new Aerospike.WritePolicy({ key: Aerospike.policy.key.SEND,});
// Establishes a connection to the serverconst client = await Aerospike.connect(config);
const data = JSON.parse(await readFile("./employees.json", "utf8"));
const bins = { employees: data.employees };
// Metadata may be passed; use null to send no metadataconst metadata = null;
await client.put(key, bins, metadata, writePolicy);
await client.close();