Skip to content
agogosml is a flexible data processing pipeline that addresses the common need for operationalizing ML models at scale
Branch: master
Clone or download
Type Name Latest commit message Commit time
Failed to load latest commit information.
agogosml Renamed eventhub_kafka to event_hub_kafka for consistency. (#307) May 3, 2019
agogosml_cli Remove env variable duplication in helm charts (#304) Mar 29, 2019
docs Converted to YML Azure Pipelines & Updated CLI Readme (#271) Feb 22, 2019
tools Replace pipenv with pip (#229) Feb 1, 2019
.dockerignore Update tests and kafka impl (#155) Nov 19, 2018
.editorconfig Added vscode and _build to gitignore and switched to 4 spaces for pyt… Nov 9, 2018
.gitignore MLeap Sample App - Server and Model Creation Projects (#194) Jan 3, 2019
AUTHORS.rst Initial CLI Implementation (#94) Nov 5, 2018
CODE_OF_CONDUCT.rst Updated Readme structure and filenames. (#173) Nov 28, 2018
CONTRIBUTING.rst Updated Readme structure and filenames. (#173) Nov 28, 2018
README.rst Update Project Readme.rst (#233) Feb 1, 2019
ROADMAP.rst Updated Readme structure and filenames. (#173) Nov 28, 2018 Add option to set AppInsights endpoint URL (#273) Feb 22, 2019



Agogosml Build status1 Agogosml Library Documentation Status
CLI Build status2 Agogosml CLI Documentation Status

Agogosml is a data processing pipeline project that addresses the common need for operationalizing ML models. The project enables you to deploy models in production at scale and aspires to provide scoring and monitoring of models on the same infrastructure (coming soon).


  • Re-usable/canonical data processing pipeline supporting multiple data streaming technologies (Kafka and Azure EventHub) and deployment to Kubernetes.
  • CI/CD pipeline using Azure DevOps to deploy versioned and immutable pipeline.
  • Blue/Green deployments, automatic role-backs or redeployment of a specific version.

Quick Install & Run

The following quick install instructions assumes you have the azure-cli, Python 3.7 (with C Compiler tools), Docker and Terraform installed.

# 1. Installing the CLI
 pip install agogosml_cli

 # 2. Create a directory for your project
 mkdir hello-agogosml
 cd hello-agogosml

 # 3. Init the project
 agogosml init

 # 4. Fill in the manifest.json (Docker Container Registry, Azure Subscription, etc).
 vi manifest.json

 # 5. Generate the code for the projects
 agogosml generate

The generated folder structure consists of the input reader, customer app and output writer as well as the Azure DevOps pipelines for CI/CD.

For more detailed information, see the User Guide


The agogosml package was developed to provide a Data Engineer with a simple configurable data pipeline consisting of three components: an input reader, app (that holds a trained ML model) and an output writer. The three components are instrumented using one Docker container per component.

Input Reader

The input reader acts as the data receiver and obtains the data required as input for the ML model. The package supports both Kafka and EventHub.

Output Writer

The output writer receives the scored data from the app and sends it onto a streaming client (a Kafka or Eventhub instance).


The app receives data from the input reader and feeds it to the ML model for scoring. Once scored the data is sent onto the output writer.

For more information about the design, see the Design Documentation



This project welcomes contributions and suggestions. Most contributions require you to agree to a Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us the rights to use your contribution. For details, visit

When you submit a pull request, a CLA-bot will automatically determine whether you need to provide a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions provided by the bot. You will only need to do this once across all repos using our CLA.

This project has adopted the Microsoft Open Source Code of Conduct. For more information see the Code of Conduct FAQ or contact with any additional questions or comments.

You can’t perform that action at this time.