Skip to main content

Provides an Acumos model runner for DCAE

Project description

Acumos DCAE Model Runner

The Acumos DCAE model runner enables Acumos Python models to be run as if they were DCAE components.

Each Acumos model method is mapped to a subscriber and publisher stream, with _subscriber and _publisher suffixes respectively. For example, a model with a transform method would have transform_subscriber and transform_publisher streams.

The model runner implements DCAE APIs such as health checks and configuration updates.

The acumos_dcae_model_runner Python package provides a command line utility that can be used to instantiate the model runner. See the tutorial for more information.

The acumos_dcae_model_runner package should be installed in the docker image that is ultimately on-boarded into DCAE. The model runner CLI utility should be the entry point of that Docker image, as shown in the Dockerfile provided in example/ directory in the root of the Acumos DCAE Model Runner repository..

Installation

The acumos_dcae_model_runner package can be installed with pip like so:

pip install acumos_dcae_model_runner

Tutorial

CLI Usage

To execute the model runner, use the provided CLI:

$ acumos_dcae_model_runner --help
usage: acumos_dcae_model_runner [-h] [--timeout TIMEOUT] [--debug] model_dir

positional arguments:
  model_dir          Directory that contains either the dumped model.zip or
                     its unzipped contents.

optional arguments:
  -h, --help         show this help message and exit
  --timeout TIMEOUT  Timeout (ms) used when fetching.
  --debug            Sets the log level to DEBUG

DCAE Onboarding Example

The python-dcae-model-runner repository has an example/ directory that shows how an Acumos model can be onboarded as a DCAE component.

After executing the steps below, the directory should have this structure:

example/
├── Dockerfile
├── dcae-artifacts
│   ├── component.json
│   ├── number-out.json
│   └── numbers-in.json
├── example-model
│   ├── metadata.json
│   ├── model.proto
│   └── model.zip
├── example_model.py
└── requirements.txt

Note: For this example, the requirements.txt file should reflect the packages and versions listed in example-model/metadata.json.

Steps

1) Create the Acumos model

The example_model.py script defines a simple Acumos model that can add two integers together. The following will generate example-model/:

python example_model.py
2) Build the docker image
docker build -t acumos-python-model-test:0.1.0 .
3) Onboard the Acumos model to DCAE

The onboarding procedure involves adding the component and data format artifacts provided in example/dcae-artifacts to the DCAE catalog.

Refer to the official DCAE onboarding documentation for the full procedure.

Acumos DCAE Model Runner Release Notes

v0.1.2

  • Removed dependency link for dcaeapplib

v0.1.1

  • Updated dependency link for dcaeapplib. It released a patch that fixed an authentication error. The dcaeapplib dependency link will be removed once dcaeapplib is hosted in PyPI.

v0.1.0

  • Initial release of the Acumos DCAE Python model runner

Contributing Guidelines

Testing

We use a combination of tox, pytest, and flake8 to test acumos. Code which is not PEP8 compliant (aside from E501) will be considered a failing test. You can use tools like autopep8 to “clean” your code as follows:

$ pip install autopep8
$ cd python-dcae-model-runner
$ autopep8 -r --in-place --ignore E501 acumos_dcae_model_runner/

Run tox directly:

$ cd python-dcae-model-runner
$ export WORKSPACE=$(pwd)  # env var normally provided by Jenkins
$ tox

You can also specify certain tox environments to test:

$ tox -e py34  # only test against Python 3.4
$ tox -e flake8  # only lint code

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Filename, size & hash SHA256 hash help File type Python version Upload date
acumos_dcae_model_runner-0.1.2-py2-none-any.whl (6.9 kB) Copy SHA256 hash SHA256 Wheel py2
acumos_dcae_model_runner-0.1.2.tar.gz (7.1 kB) Copy SHA256 hash SHA256 Source None

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page