orchestrate
Advanced tools
Orchestrate is a database service. It is a simple REST API that is optimized for queries. Orchestrate combines full-text search, graph, time-series, and key/value.
Node Driver for Orchestrate.io.
$ npm install orchestrate
Currently, Orchestrate.js runs against the actual Orchestrate API. At the moment, there is no available local version to work with.
Ensure all dependencies are installed within the orchestrate director by running
$ npm install
To run tests:
$ npm test
var db = require('orchestrate')(token)
Note, the client defaults to the Amazon US East Datacenter. If you've created your Application in a different datacenter, you'll need to configure the client with that Datacenter's Api URL. For example, for Amazon EU West:
var oio = require('orchestrate')
oio.ApiEndPoint = "api.aws-eu-west-1.orchestrate.io"
var db = oio(token)
Please see the Orchestrate MDC Docs for more information on Multi-Datacenter.
Orchestrate comes with support for GET/PUT/DEL for key-value queries, as well as search, graph, and events. Documentation can be found here.
All queries are promise based. Just as a typical function would return a callback containing an error field followed by a result, orchestrate.js returns then and fail methods.
To get a value:
db.get('collection', 'key')
.then(function (result) {
})
.fail(function (err) {
})
To set a value:
db.put('collection', 'key', {
"name": "Steve Kaliski",
"hometown": "New York, NY",
"twitter": "@stevekaliski"
})
.then(function (result) {
})
.fail(function (err) {
})
Or, setting a value and allowing the server to generate a key:
db.post('collection', {
"name": "Steve Kaliski",
"hometown": "New York, NY",
"twitter": "@stevekaliski"
})
.then(function (result) {
})
.fail(function (err) {
})
To merge (or update) new values into an existing key, construct a partial document with the desired changes and then use merge:
db.merge('collection', 'key', {
"name": "Stephen Kaliski"
})
.then(function (result) {
})
.fail(function (err) {
})
Alternatively, you can apply a series of controlled changes to a key by constructing a patch:
db.newPatchBuilder('collection', 'key')
.add('age', 25)
.replace('hometown', 'NY')
.apply()
.then(function (result) {
// All changes were applied successfully
})
.fail(function (err) {
// No changes were applied
})
Orchestrate also supports conditional put statements that determines whether or not the store operation will occur. db.put takes a fourth argument match which is either the ref value or false. If a ref value is provided an update will occur if there is a valid match, if false is provided, a create will occur if there is no match.
db.put('collection', 'key', data, 'cbb48f9464612f20') // update
db.put('collection', 'key', data, false) // create
To remove a value:
db.remove('collection', 'key', true)
.then(function (result) {
})
.fail(function (err) {
})
The last parameter is optional. If supplied the ref history will be removed as well.
To get a value at a specific ref:
db.get('collection', 'key', 'ref')
.then(function (result) {
})
.fail(function (err) {
})
To list refs for a particular key in a collection:
db.list_refs('collection', 'key')
.then(function (result) {
var items = result.body.results;
})
.fail(function (err) {
})
There is no need to explicitly create a collection. Collections are implicitly created when putting a key/value object.
To list items in a collection, you can use collection listings.
db.list('collection')
.then(function (result) {
var items = result.body.results;
})
.fail(function (err) {
})
Collection listings allow you to page through your collection in key order (sorted lexicographically so be aware of that if you have numeric keys). It is also useful to list parts of your collection starting from a particular key. For example, to list the first 10 keys starting from key 'c':
db.list('address-book', {limit:10, startKey:'c'})
.then(function (result) {
})
.fail(function (err) {
})
Note: if there is no item with key 'c', the first page will simply have the first 10 results that sort after 'c'.
Collection listings support pagination. If there are more items that follow the page that was retrieved, the result will have a 'links.next' that you can use to fetch the next page.
db.list('address-book', {limit:10, startKey:'c'})
.then(function (page1) {
// Got First Page
if (page1.links && page1.links.next) {
page1.links.next.get().then(function (page2) {
// Got Second Page
})
}
})
.fail(function (err) {
})
db.deleteCollection('users')
To run a quick search, you can simply provide the collection you'd like to search within, your query, and optionally, any query parameters like a list or sort argument. Currently, Orchestrate supports the Lucene query syntax.
db.search('collection', 'query', {
sort: 'value.sort:desc',
limit: 5,
offset: 2
})
.then(function (result) {
})
.fail(function (err) {
})
The more verbose SearchBuilder is also available for a more stately approach:
db.newSearchBuilder()
.collection('users')
.limit(100)
.offset(10)
.sort('name', 'desc')
.sort('age', 'asc')
.aggregate('stats', 'value.name')
.stats('username')
// these two range aggregates are identical
// but they use different interfaces
.range('coolness', '*~1:1~2:2~*')
.range('radness', function (builder) {
return builder
.before(1)
.between(1, 2)
.after(2);
})
// these two distance aggregates are identical
// but they use different interfaces
.distance('location', '*~1:1~2:2~*')
.distance('hometown', function (builder) {
return builder
.before(1)
.between(1, 2)
.after(2);
})
.time_series('path', 'day')
.query('steve')
Searching Events is also supported. Event Searching is done by adding a '@path.kind' predicate to the query to indicate what should be searched. By default, Orchestrate will only Search for 'item's in the collection.
db.newSearchBuilder()
.collection('users')
.query('@path.kind:event AND steve')
There is a builder method to set the 'kind' for you:
db.newSearchBuilder()
.collection('users')
.kinds('event')
.query('steve')
This query will find all events in the users collection that have a field containing 'steve'. You can further limit what event types are searched by adding another @path metadata predicate:
db.newSearchBuilder()
.collection('users')
.kinds('event')
.query('@path.type:activities AND steve')
This further restricts the search to event type 'activities'.
You can also Search both items and events.
db.newSearchBuilder()
.collection('users')
.kinds('item', 'event')
.query('steve')
The result items will have a mix of matching items and events. Each result has a 'path' element, and the 'path.kind' element can be used to determine what the result kind is. For example:
{
"count": 2,
"total_count": 2,
"results": [
{
"path": {
"collection": "users",
"kind": "item",
"key": "sjkaliski@gmail.com",
"ref": "74c22b1736b9d50e",
"reftime": 1424473968410
},
"value": {
"name": "Steve Kaliski",
"hometown": "New York, NY",
"twitter": "@stevekaliski"
},
"score": 3.7323708534240723,
"reftime": 1424473968410
},
{
"path": {
"collection": "users",
"kind": "event",
"key": "byrd@bowery.io",
"type": "activities",
"timestamp": 1412787145997,
"ordinal": 406893558185357300,
"ref": "82eafab14dc84ed3",
"reftime": 1412787145997,
"ordinal_str": "05a593890d087000"
},
"value": {
"activity": "followed",
"user": "sjkaliski@gmail.com",
"userName": "Steve Kaliski"
},
"score": 2.331388473510742,
"reftime": 1412787145997
}
]
}
For more information about Orchestrate search, read the docs.
An awesome feature Orchestrate includes is the ability to generate graphs between collections. For example, consider the collections users and movies. Some user Steve will like a variety of movies. We can generate this relationship:
db.newGraphBuilder()
.create()
.from('users', 'Steve')
.related('likes')
.to('movies', 'Superbad')
We can then look up all the different items Steve likes:
db.newGraphReader()
.get()
.from('users', 'Steve')
.related('likes')
We can even take this another step further:
db.newGraphReader()
.get()
.from('users', 'Steve')
.related('friends', 'likes')
This will return all of the things that friends of Steve have liked. This assumes a friend relation has previously been defined between Steve and another user.
Orchestrate supports offsets and limits for graph relationships as well. To set those values:
db.newGraphReader()
.get()
.limit(1)
.offset(1)
.from('users', 'Steve')
.related('friends', 'likes')
If we want to delete a graph relationship:
db.newGraphBuilder()
.remove()
.from('users', 'Steve')
.related('likes')
.to('movies', 'Superbad')
Events are time-ordered objects that exist with the context of a Key-Value object. Consider comments on a post or messages in a thread.
Creating an event:
db.newEventBuilder()
.from('users', 'Steve')
.type('update')
.data({"text": "Hello!"})
.create()
Creating an event at a specified time:
db.newEventBuilder()
.from('users', 'Steve')
.type('update')
.time(1384534722568)
.data({"text": "Hello!"})
.create()
Listing events:
db.newEventReader()
.from('users', 'Steve')
.start(1384534722568)
.end(1384535726540)
.type('update')
.list()
Getting a specific event:
db.newEventReader()
.from('users', 'Steve')
.time(1369832019085)
.ordinal(9)
.type('update')
.get()
Updating an event:
db.newEventBuilder()
.from('users', 'Steve')
.type('update')
.time(1369832019085)
.ordinal(9)
.data({
"text": "Orchestrate is awesome!"
})
.update()
Updating an event, conditionally:
db.newEventBuilder()
.from('users', 'Steve')
.type('update')
.time(1369832019085)
.ordinal(9)
.data({
"text": "Orchestrate is awesome!"
})
.ref('ae3dfa4325abe21e')
.update()
Deleting an event:
db.newEventBuilder()
.from('users', 'Steve')
.type('update')
.time(1369832019085)
.ordinal(9)
.remove()
If you want to make sure your key is valid, you can simply "ping" Orchestrate.
db.ping()
.then(function () {
// you key is VALID
})
.fail(function (err) {
// your key is INVALID
})
FAQs
Orchestrate is a database service. It is a simple REST API that is optimized for queries. Orchestrate combines full-text search, graph, time-series, and key/value.
The npm package orchestrate receives a total of 38 weekly downloads. As such, orchestrate popularity was classified as not popular.
We found that orchestrate demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 8 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
Company News
Socket is joining TC54 to help develop standards for software supply chain security, contributing to the evolution of SBOMs, CycloneDX, and Package URL specifications.
Security News
PyPI now allows maintainers to archive projects, improving security and helping users make informed decisions about their dependencies.
Research
Security News
Malicious npm package postcss-optimizer delivers BeaverTail malware, targeting developer systems; similarities to past campaigns suggest a North Korean connection.