Welcome to Chariot Base documentation!

Chariot Base

epl pypi doc

Base utilities for chariot micro-services.

Development

Encrypt application secrets, with the folling command

$ gpg -c --batch --passphrase test config.json

Features

  • Connection to Influx DB
  • Connection to MQTT broker
  • Connection to Cloudant
  • Connection to IBM Watson IoT service

Credits

This package was created with Cookiecutter and the audreyr/cookiecutter-pypackage project template.

Installation

Stable release

To install Chariot Privacy Engine, run this command in your terminal:

$ pip install chariot_base

This is the preferred method to install Chariot Base, as it will always install the most recent stable release.

If you don’t have pip installed, this Python installation guide can guide you through the process.

From sources

The sources for Chariot Privacy Engine can be downloaded from the Gitlab repo.

You can either clone the public repository:

$ git clone git@gitlab.com:chariot-h2020/chariot_base.git

Or download the tarball:

$ curl  -OL https://gitlab.com/chariot-h2020/chariot_base/-/archive/master/chariot_base-master.zip

Then install requirements for a Debian like system, with the following command:

$ sudo apt-get install python-dev libgmp3-dev

Once you have a copy of the source and requirement are installed, you can install it with:

$ python setup.py install

Usage

To use Chariot Privacy Engine in a project:

import chariot_base

Modules

class chariot_base.connector.local.LocalConnector[source]

All subscribers/publisers at Chariot project should extend this class

clear()[source]

Reinitialize the connector

close_span(span)[source]

Close a logging span

Parameters:span – Span to close
inject_tracer(tracer)[source]

Inject an opentracing client

Parameters:tracer – the opentracing client
on_connect(client, flags, rc, properties)[source]

The handler run when the connections is established

Parameters:
  • client – the subscribed MQTT client
  • flags
  • rc
  • properties – Custom properties
on_disconnect(client, packet)[source]

The handler run when the connections is fineshed

Parameters:
  • client – the subscribed MQTT client
  • packet
on_message(client, topic, payload, qos, properties)[source]

Handler for new message

Parameters:
  • client – the subscribed MQTT client
  • topic – the MQTT topic
  • payload – the message
  • qos – MQTT broker quality of service
  • properties – Custom properties
on_subscribe(client, mid, qos)[source]

The handler run when the client subscribed to a new topic

Parameters:
  • client – the subscribed MQTT client
  • mid
  • qos – MQTT broker quality of service
publish(topic, msg, qos=1)[source]

Publish to a topic

Parameters:
  • msg – the published message
  • qos – MQTT broker quality of service
register_for_client(client)[source]

Register handlers to the client.

Parameters:client – Client to register handlers
set_up_tracer(options)[source]

Configure a new opentracing client

Parameters:options – options to configure the new client
start_span(span_id, child_span=None)[source]

Start a new logging span

Parameters:
  • span_id – identifier of a new logging span
  • child_span – parent span
subscribe(topic, qos=1)[source]

Subscribe to a topic

Parameters:
  • topic – Which topic the subscriber should listen for new message.
  • qos – MQTT broker quality of service
chariot_base.connector.local.create_client(options, postfix='_client')[source]

Create a new GMQTT client

Parameters:options – Options for client initialization
Para postfix:Unique postfix for the client
class chariot_base.connector.watson.WatsonConnector(options)[source]
publish(point)[source]
Parameters:point – A point represent received message.
Returns:True if event publish is successfull.
class chariot_base.model.alert.Alert(name, msg=None, severity=100)[source]

Describe each alert raised by Chariot

dict()[source]

Converts alert object to dictionary

class chariot_base.model.point.DataPointFactory(db, table)[source]

Converts to a new point

from_json_string(msg)[source]

From JSON message payload

from_mqtt_message(message)[source]

From mosquitto message payload

class chariot_base.model.message.Message(sensor_id, value)[source]

Describe message passed between Chariot’s components

class chariot_base.model.subscriber.Subscriber(subscriber_id)[source]

Chariot gateway subscriber

class chariot_base.tests.utils.Callbacks[source]
on_message(client, topic, payload, qos, properties)[source]

Handler for new message

Parameters:
  • client – the subscribed MQTT client
  • topic – the MQTT topic
  • payload – the message
  • qos – MQTT broker quality of service
  • properties – Custom properties
on_subscribe(client, mid, qos)[source]

The handler run when the client subscribed to a new topic

Parameters:
  • client – the subscribed MQTT client
  • mid
  • qos – MQTT broker quality of service

Contributing

Contributions are welcome, and they are greatly appreciated! Every little bit helps, and credit will always be given.

You can contribute in many ways:

Types of Contributions

Report Bugs

Report bugs at https://gitlab.com/chariot-h2020/chariot_base/issues.

If you are reporting a bug, please include:

  • Your operating system name and version.
  • Any details about your local setup that might be helpful in troubleshooting.
  • Detailed steps to reproduce the bug.

Fix Bugs

Look through the GitLab issues for bugs. Anything tagged with “bug” and “help wanted” is open to whoever wants to implement it.

Implement Features

Look through the GitLab issues for features. Anything tagged with “enhancement” and “help wanted” is open to whoever wants to implement it.

Write Documentation

Chariot Base could always use more documentation, whether as part of the official Chariot Base docs, in docstrings, or even on the web in blog posts, articles, and such.

Submit Feedback

The best way to send feedback is to file an issue at https://gitlab.com/chariot-h2020/chariot_base/issues.

If you are proposing a feature:

  • Explain in detail how it would work.
  • Keep the scope as narrow as possible, to make it easier to implement.
  • Remember that this is a volunteer-driven project, and that contributions are welcome :)

Get Started!

Ready to contribute? Here’s how to set up chariot_base for local development.

  1. Fork the chariot_base repo on GitLab.

  2. Clone your fork locally:

    $ git clone git@gitlab.com:chariot-h2020/chariot_base.git
    
  3. Install your local copy into a virtualenv. Assuming you have virtualenvwrapper installed, this is how you set up your fork for local development:

    $ mkvirtualenv chariot_base
    $ cd chariot_base/
    $ python setup.py develop
    
  4. Create a branch for local development:

    $ git checkout -b name-of-your-bugfix-or-feature
    

    Now you can make your changes locally.

  5. When you’re done making changes, check that your changes pass flake8 and the tests, including testing other Python versions with tox:

    $ flake8 chariot_base tests
    $ python setup.py test or py.test
    $ tox
    

    To get flake8 and tox, just pip install them into your virtualenv.

  6. Commit your changes and push your branch to GitLab:

    $ git add .
    $ git commit -m "Your detailed description of your changes."
    $ git push origin name-of-your-bugfix-or-feature
    
  7. Submit a pull request through the GitLab website.

Pull Request Guidelines

Before you submit a pull request, check that it meets these guidelines:

  1. The pull request should include tests.
  2. If the pull request adds functionality, the docs should be updated. Put your new functionality into a function with a docstring, and add the feature to the list in README.rst.

Tips

To run a subset of tests:

$ python -m unittest tests.test_chariot_base

Deploying

A reminder for the maintainers on how to deploy. Make sure all your changes are committed (including an entry in HISTORY.rst). Then run:

$ bumpversion patch # possible: major / minor / patch
$ git push
$ git push --tags

GitLab will then deploy to PyPI if tests pass.

Changelog

0.5.3 (2019-02-25)

  • Add IoTLWrapper

0.5.0 (2019-02-19)

  • Each data point gets a random guid.
  • Add support for distributed tracing.
  • Read JSON configuration.
  • Migrate to gmqtt, drop use of python-mqtt.

0.2.3 (2018-11-12)

  • Pass connection options to cloudant data storage
  • Pass connection options to watson connector
  • Modify how I write to the local storage
  • Add test for data point
  • Add test for sign & verify
  • Custom (Integrated Encryption Scheme) IES encrypt/decrypt
  • Bitwise permission checking

0.1.10 (2018-10-01)

  • Add connector
  • Update model
  • Add various data source utilities

0.1.1 (2018-10-01)

  • Add common model files

0.1.0 (2018-09-28)

  • First release on GitLab.

Credits

Development Lead

Contributors

None yet. Why not be the first?

Indices and tables