Quick Start with Document Store¶
Note
If you are new to Macrometa GDN, we strongly recommend reading Essentials of Macrometa GDN.
Documents in GDN are JSON objects. These objects can be nested (to any depth) and may contain lists. Each document has a unique primary key which identifies it within its collection. Furthermore, each document is uniquely identified by its document handle across all collections. Different revisions of the same document (identified by its handle) can be distinguished by their document revision. Any transaction only ever sees a single revision of a document.
For example:
{
"_id" : "myusers/3456789",
"_key" : "3456789",
"_rev" : "14253647",
"firstName" : "John",
"lastName" : "Doe",
"address" : {
"street" : "Road To Nowhere 1",
"city" : "Gotham"
},
"hobbies" : [
{name: "swimming", howFavorite: 10},
{name: "biking", howFavorite: 6},
{name: "programming", howFavorite: 4}
]
}
All documents contain special attributes:
- the document handle is stored as a string in
_id
, - the document's primary key in
_key
and - the document revision in
_rev
.
The value of the _key
attribute can be specified by the user when creating a document. _id
and _key
values are immutable once the document has been created. The _rev
value is maintained by GDN automatically.
Pre-requisite¶
Let's assume your
- Tenant name is
nemo@nautilus.com
and - User password is
xxxxxx
.
Driver download¶
pyC8 requires Python 3.5+. Python 3.6 or higher is recommended
To install pyC8, simply run
$ pip3 install pyC8
or, if you prefer to use conda:
conda install -c conda-forge pyC8
or pipenv:
pipenv install --pre pyC8
Once the installation process is finished, you can begin developing applications in Python.
With Yarn or NPM
yarn add jsc8
(or)
npm install jsc8
If you want to use the driver outside of the current directory, you can also install it globally using the `--global` flag:
npm install --global jsc8
From source,
git clone https://github.com/macrometacorp/jsc8.git
cd jsC8
npm install
npm run dist
Connect to GDN¶
The first step in using GDN is to establish a connection to a region. When this code executes, it initializes the server connection to the **closest* region to your location.
from c8 import C8Client
print("--- Connecting to C8")
# Simple Way
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
# To use advanced options
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443)
const jsc8 = require("jsc8");
// Simple Way
const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// ----- OR -----
const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// To use advanced options
const client = new jsc8("https://gdn.paas.macrometa.io");
Get GeoFabric Details¶
To get details of fabric,
from c8 import C8Client
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
print("Get geo fabric details...")
print(client.get_fabric_details())
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
async function getFabric() {
try{
await console.log("Getting the fabric details...");
let result = await client.get();
await console.log("result is: ", result);
} catch(e){
await console.log("Fabric details could not be fetched because "+ e);
}
}
getFabric();
Create Collection¶
We can now create collection in the fabric. To do this, first you connect to fabric and then create a collection called employees
.
The below example shows the steps.
# Simple Approach
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
client.create_collection(name='employees')
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
async function createCollection() {
await console.log("Creating the collection employees under demoFabric...");
let collectionDetails;
try{
collectionDetails = await client.createCollection('employees');
await console.log("The collection details are: ", collectionDetails);
} catch(e){
return "Collection creation did not succeed due to " + e;
}
return "Collection " + collectionDetails.name + " created successfully";
}
createCollection().then(console.log);
Create Index¶
Let's add a hash_index
called emails to our collection employees. Please refer to reference guide for details on other available index types.
# Simple Approach
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
print("Add Hash Index", client.add_hash_index('employees', fields=['continent', 'country'], unique=True)
)
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
async function createIndex() {
await console.log("Creating the index on collection employees under demoFabric...");
let index;
try{
index = await client.addHashIndex("employees", ["email", "_key"]);
await console.log("The index details are: ", index);
} catch(e){
return "Index creation did not succeed due to " + e;
}
return "Index created successfully";
}
createIndex().then(console.log);
Insert Documents¶
Let's insert documents to the employees collection as shown below.
# Simple Approach
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
client.insert_document(collection_name='employees', document={'_key':'Jean', 'firstname': 'Jean', 'lastname':'Picard', 'email':'jean.picard@macrometa.io'})
docs = [
{'_kefabricy':'James', 'firstname': 'James', 'lastname':'Kirk', 'email':'james.kirk@mafabriccrometa.io'},
{'_kefabricy': 'Han', 'firstname': 'Han', 'lastname':'Solo', 'email':'han.solo@macrfabricometa.io'},
{'_kefabricy': 'Bruce', 'firstname': 'Bruce', 'lastname':'Wayne', 'email':'bruce.wayne@mfabricacrometa.io'}
]
client.insert_document(collection_name='employees', document=docs)
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
//Variables
const docJean = {'_key':'Jean',
'firstname': 'Jean',
'lastname':'Picard', 'email':'jean.picard@macrometa.io'};
const docJames = {'_key':'James',
'firstname': 'James', 'lastname':'Kirk', 'email':'james.kirk@macrometa.io'};
const docHan = {'_key': 'Han',
'firstname': 'Han',
'lastname':'Solo', 'email':'han.solo@macrometa.io'};
const docBruce = {'_key': 'Bruce',
'firstname': 'Bruce', 'lastname':'Wayne', 'email':'bruce.wayne@macrometa.io'};
const docs = [docJean, docJames, docHan, docBruce];
async function populate() {
await console.log("Creating the collection object to be used and populating with documents...");
await client.insertDocumentMany("employees", docs);
await console.log("collection populated with documents");
}
populate();
Query documents using C8QL¶
C8QL is C8's query language. You can execute C8QL query on our newly created collection employees to get its contents.
The query FOR employee IN employees RETURN employee
is equivalent to SQL's SELECT query.
# Simple Approach
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
client.execute_query('FOR employee IN employees RETURN employee')
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
async function c8Queries() {
const result = await client.executeQuery(
"FOR employee IN employees RETURN employee"
);
await console.log(result);
}
c8Queries();
Get realtime updates¶
Example for real-time updates from a collection in fabric:
# Simple Approach
client = C8Client(protocol='https', host='gdn.paas.macrometa.io', port=443,
email='nemo@nautilus.com', password='xxxxx',
geofabric='_system')
#--------------------------------------------------------------
def callback_fn(event):
print(event)
#--------------------------------------------------------------
client.on_change("employees", callback=callback_fn)
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
async function callback_fn(collection){
await console.log("Connection open on ", collection.name);
}
async function realTimeListener() {
const listener = await client.onCollectionChange("employees");
listener.on('message',(msg) => console.log("message=>", msg));
listener.on('open',() => {
this.callback_fn(collection);
});
listener.on('close',() => console.log("connection closed"));
}
realTimeListener();
Spot Collections¶
Create a geo-fabric with spot region capabilities. Then create a collection that is designated as a spot collection. A geo-fabric can contain both regular and spot collections.
from c8 import C8Client
import json
spot_fabric_name = "spot-geo-fabric"
spot_collection_name = "spot-collection"
# Initialize the client for C8DB.
client = C8Client(protocol='https', host='gdn-sfo2.prod.macrometa.io', port=443,
email="nemo@nautilus.com", password="xxxxxx")
#Create a geo-fabric and pass one of the spot regions. You can use the SPOT_CREATION_TYPES for the same. If you use AUTOMATIC, a random spot region will be assigned by the system.
# If you specify None, a geo-fabric is created without the spot properties. If you specify spot region,pass the corresponding spot region in the spot_dc parameter.
print("Create spot collection ...")
spot_collection = client.create_collection(name=spot_collection_name, spot_collection=True)
print("Insert documents into spot collection ...")
spot_collection.insert({'firstname': 'Jean', 'lastname':'Picard', 'email':'jean.picard@macrometa.io'})
spot_collection.insert({'firstname': 'James', 'lastname':'Kirk', 'email':'james.kirk@macrometa.io'})
spot_collection.insert({'firstname': 'Han', 'lastname':'Solo', 'email':'han.solo@macrometa.io'})
spot_collection.insert({'firstname': 'Bruce', 'lastname':'Wayne', 'email':'bruce.wayne@macrometa.io'})
print("Execute C8QL query...")
cursor = client.execute_query('FOR doc IN @@collection RETURN doc', bind_vars={"@collection":spot_collection_name})
print("Retrieve documents...")
docs = [document for document in cursor]
print(docs)
print("clearing collection")
client.delete_collection(spot_collection_name)
const jsc8 = require("jsc8");
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
//Variables
const collection_name = "accounts";
async function spotCollection() {
try{
console.log("Creating the collection accounts...");
const exists_coll = await client.hasCollection(collection_name);
if (exists_coll === false) {
await client.createCollection(collection_name, {isSpot: true});
}
}
catch (e) {
await console.log("Collection creation did not succeed due to " + e);
}
}
spotCollection();
Query as API¶
Query as API (aka RESTQL) enables developers to quickly convert saved C8QL queries into geo-distributed REST APIs. This eliminates the need for separate backend servers & containers for CRUD operations.
from c8 import C8Client
fed_url = "gdn.paas.macrometa.io"
guest_mail = "nemo@nautilus.com"
guest_password = "xxxxxx"
geo_fabric = "_system"
collection_name = "person"
value = "INSERT {'firstname':@firstname, 'lastname':@lastname, 'email':@email, 'zipcode':@zipcode, '_key': 'abc'} IN %s" % collection_name
parameter = {"firstname": "", "lastname": "", "email": "", "zipcode": ""}
insert_data = {"query": {"name": "insertRecord", "parameter": parameter, "value": value}}
get_data = {"query": {"name": "getRecords", "value": "FOR doc IN %s RETURN doc" % collection_name}}
update_data = {"query": {"name": "updateRecord", "value": "UPDATE 'abc' WITH { \"lastname\": \"cena\" } IN %s" % collection_name }}
delete_data= {"query": {"name": "deleteRecord", "value": "REMOVE 'abc' IN %s" % collection_name}}
get_count = {"query": {"name": "countRecords", "value": "RETURN COUNT(FOR doc IN %s RETURN 1)" % collection_name}}
if __name__ == '__main__':
print("\n ------- CONNECTION SETUP ------")
print("tenant: {}, geofabric:{}".format(guest_mail, geo_fabric))
client = C8Client(protocol='https', host=fed_url, port=443,
email=guest_mail, password=guest_password,
geofabric=geo_fabric)
print("\n ------- CREATE GEO-REPLICATED COLLECTION ------")
if client.has_collection(collection_name):
print("Collection exists")
else:
employees = client.create_collection(collection_name)
print("Created collection: {}".format(collection_name))
print("\n ------- CREATE RESTQLs ------")
client.create_restql(insert_data) # name: insertRecord
client.create_restql(get_data) # name: getRecords
client.create_restql(update_data) # name: updateRecord
client.create_restql(delete_data) # name: deleteRecord
client.create_restql(get_count) # name: countRecords
print("Created RESTQLs:{}".format(client.get_restqls()))
print("\n ------- EXECUTE RESTQLs ------")
print("Insert data....")
response = client.execute_restql(
"insertRecord",
{"bindVars": {"firstname": "john", "lastname": "doe",
"email": "john.doe@macrometa.io", "zipcode": "511037"}})
print("Get data....")
response = client.execute_restql("getRecords")
print("Update data....")
response = client.execute_restql("updateRecord")
print("Get data....")
response = client.execute_restql("getRecords")
print("Count records....")
response = client.execute_restql("countRecords")
print("Delete data....")
response = client.execute_restql("deleteRecord")
print("\n ------- DELETE RESTQLs ------")
client.delete_restql("insertRecord")
client.delete_restql("getRecords")
client.delete_restql("updateRecord")
client.delete_restql("countRecords")
client.delete_restql("deleteRecord")
print("\n ------- DONE ------")
const jsc8 = require('jsc8');
// Crete a authenticated instance with Token / Apikey
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", token: "XXXX", fabricName= '_system'});
// const client = new jsc8({url: "https://gdn.paas.macrometa.io", apiKey: "XXXX", fabricName= '_system'});
// await console.log("Authentication done!!...");
// Or use Email & Password to Authenticate client instance
const client = new jsc8("https://gdn.paas.macrometa.io");
await client.login("nemo@nautilus.com", "xxxxxx");
//Variables
const collection_name = "addresses" + Math.floor(1000 + Math.random() * 9000).toString();
//Queries
const insert_data = "INSERT {'firstname':@firstname, 'lastname':@lastname, 'email':@email, 'zipcode':@zipcode, '_key': 'abc'} IN " + collection_name;
const get_data = "FOR doc IN " + collection_name + " RETURN doc";
const update_data = "UPDATE 'abc' WITH {'lastname': @lastname } IN " + collection_name;
const delete_data = "REMOVE 'abc' IN " + collection_name;
const get_count = "RETURN COUNT(FOR doc IN " + collection_name + " RETURN 1)";
async function restqldemo() {
console.log("------- CREATE GEO-REPLICATED COLLECTION ------");
const collection = await client.createCollection(collection_name);
console.log("Collection " + collection_name + " created.\n");
console.log("------- SAVING THE QUERIES ------");
await client.createRestql("insertData", insert_data, {});
await client.createRestql("getData", get_data, {});
await client.createRestql("updateData", update_data, {});
await client.createRestql("deleteData", delete_data, {});
await client.createRestql("getCount", get_count, {});
console.log("Saved Queries Successfully\n");
console.log("------- EXECUTING THE QUERIES ------");
const bindVars = {
"firstname": "john", "lastname": "doe",
"email": "john.doe@macrometa.io", "zipcode": "511037"
};
await client.executeRestql("insertData", bindVars);
console.log("Data Inserted \n");
const res = await client.executeRestql("getData");
console.log("Output of get data query:");
console.log(res.result);
console.log("\n");
await client.executeRestql("updateData", { "lastname": "mathews" });
console.log("Data updated \n");
const data = await client.executeRestql("getData");
console.log("Output of get data query after update:");
console.log(data.result);
console.log("\n");
const count = await client.executeRestql("getCount");
console.log("Count:");
console.log(count.result);
await client.executeRestql("deleteData");
}
restqldemo().then(console.log("Starting Execution"));