qabal 0.0.4

Installation

pip install qabal

Try It For Yourself

Qabal has a simple API that revolves around attaching functions to a Session object.

You define routes in Qabal using a query DSL that resembles Python conditional statements. These get “compiled” into more traditional message broker routes.

from qabal import Session, Item

def foo(item):
    item['foo'] = 'foo'
    return item

def bar(item):
    item['bar'] = 'bar'
    return item

def baz(item):
    item['baz'] = 'baz'
    return item

def bar_baz(item):
    item['bar'] = 'bar!'
    item['baz'] = 'baz!'
    return item

def parameters_are_okay_too(foo, bar):
    return {'baz': foo+bar}

# If your trigger query doesn't use the Qabal query language, an analytic need not even depend on Qabal.
class AnalyticWithMetadata:
    __trigger__ = Item['baz'] == 'baz!'
    __inject__ = True
    __creates__ = 'qux'

    def __call__(self, baz):
        return baz + '?'

example = AnalyticWithMetadata()
# Despite all the Qabal metadata, this analytic still maintains a normal API.
print(example('hello')) # Outputs: 'hello?'

sess = Session(provenance='extended') # Qabal records a ton of information in this mode.
sess.add(foo, Item['type'] == 'foo')
sess.add(bar, Item['foo'] == 'foo')
res = sess.feed({'type': 'foo'})
print(res)
print(res.provenance)

# The session is mutable at any time.
handle = sess.add(bar_baz, Item['bar'] == 'bar')
res = sess.feed({'type': 'foo'})
sess.remove(handle)
print(res)

sess.add(bar_baz, Item['bar'] == 'bar')
# Analytics with metadata don't need a route
sess.add(example)
res = sess.feed({'type': 'foo'})
print(res)