Skip to content

Library for running detection, clustering or classification ai pipelines using ApacheBeam

License

Notifications You must be signed in to change notification settings

mbari-org/aipipeline

Repository files navigation

MBARI Python

aipipeline is a library for running ai pipelines and monitoring the performance of the pipelines, e.g. accuracy, precision, recall, F1 score. This may include object detection, clustering, classification, and vector search algorithms. It is designed to be used for a number of projects at MBARI that require advanced workflows to process large amounts of images or video. After workflows are developed, they may be moved to the project repositories for production use. The roadmap includes adding the core functionality of some of the processing components to more broad use in the MBARI AI ecosystem.

See the MBARI AI documentation for more information on the tools and services used in the pipelines.


Example plots from the t-SNE, confusion matrix and accuracy analysis of examplar data.

example tsne plots example cm_ac


Requirements

Three tools are required to run the code in this repository:

Anaconda environment

This is a package manager for python. We recommend using the Miniconda version of Anaconda. Install on Mac OS X with the following command:

brew install miniconda

or on Ubuntu with the following command:

sudo apt install miniconda

This is a containerization tool that allows you to run code in a container.

just tool.

This is a handy tool for running scripts in the project. This is easier to use than make and more clean than bash scripts. Try it out!

Install on Mac OS X with the following command:

port install just

or on Ubuntu with the following command:

sudo apt install just

Installation

Clone the repository and run the setup command.

git clone http://github.com/mbari-org/aipipeline.git
cd aipipeline
just setup

Sensitive information is stored in a .env file in the root directory of the project, so you need to create a .env file with the following contents in the root directory of the project:

TATOR_TOKEN=your_api_token
REDIS_PASSWORD=your_redis_password
ENVIRONMENT=testing or production

Usage

Recipes are available to run the pipelines. To see the available recipes, run the following command:

just list
Command Description
list List recipes
install Setup the environment
cp-env Copy the default .env file to the project
update_trackers Update the environment. Run this command after checking out any code changes
update-env Update environment
cp-core Copy core dev code to the project on doris
cp-dev-cfe Copy cfe dev code to the project on doris
cp-dev-ptvr Copy planktivore dev code to the project on doris
cp-dev-uav Copy uav dev code to the project on doris
cp-dev-bio Copy bio dev code to the project on doris
cp-dev-i2map Copy i2map dev code to the project on doris
init-labels project='uav' leaf_type_id='19' Initialize labels for quick lookup, e.g. just init-labels uav 19
plot-tsne-vss project='uav' Generate a t-SNE plot of the VSS database
optimize-vss project='uav' *more_args="" Optimize the VSS database
calc-acc-vss project='uav' Calculate accuracy of the VSS database; run after download, then optimize
reset-vss-all Reset the VSS database, removing all data. Proceed with caution!
reset-vss project='uav' Reset the VSS database for the specified project
remove-vss project='uav' *more_args="" Remove an entry from the VSS database
init-vss project='uav' *more_args="" Initialize the VSS database for a project
load-vss project='uav' Load computed exemplars into the VSS database
load-cfe-isiis-videos *more_args="" Load cfe ISII mission videos
load-ptvr-images images='tmp/roi' *more_args="" Load planktivore ROI images
cluster-ptvr-images *more_args="" Cluster planktivore ROI images
load-ptvr-clusters clusters='tmp/roi/cluster.csv' *more_args="" Load planktivore ROI clusters
rescale-ifcb-images collection="2014" Rescale planktivore ROI images
rescale-ptvr-images collection="aidata-export-03-low-mag" Rescale planktivore ROI images
download-rescale-ptvr-images collection="aidata-export-03-low-mag" Download and rescale planktivore ROI images
cluster-uav *more_args="" Cluster UAV mission
detect-uav *more_args="" Detect UAV mission
detect-uav-test Detect UAV mission data for testing
load-uav-images Load UAV mission images
load-uav type="cluster" Load UAV detections/clusters
fix-uav-metadata Fix UAV metadata (lat/lon/alt)
compute-saliency project='uav' *more_args="" Compute saliency for downloaded VOC data and update Tator DB
crop project='uav' *more_args="" Crop detections from VOC downloads
download-crop project='uav' *more_args="" Download and crop with defaults
download project='uav' Download only
cluster project='uav' *more_args="" Cluster only
predict-vss project='uav' image_dir='/tmp/download' *more_args="" Predict images using the VSS database
run-ctenoA-test Run strided inference on a single video
run-ctenoA-prod Run strided inference on a collection of videos
run-mega-inference Run mega strided inference on a single video
run-mega-track-bio-video video='...' gpu_id='0' Track single video for bio project
run-m video='...' gpu_id='0' Same as above, alternative name
run-mega-bio-dive dive='...' gpu_id='0' Run strided pipeline on a dive for bio project
run-mega-track-bio-dive dive='...' gpu_id='0' Run tracking pipeline on full dive for bio
run-mega-track-i2map-video video='...' gpu_id='0' Track i2MAP video
run-mega-stride-i2map-dive dive='...' gpu_id='0' Stride pipeline on i2MAP dive
run-mega-track-test-1min Test pipeline on a 1-min video
run-mega-track-test-fastapiyv5 Test pipeline with FastAPI
cluster-i2mapbulk Inference + cluster on i2MAP bulk data
download-cluster-i2map version="Baseline" Download + cluster on i2MAP data
cluster-ptvr-sweep roi_dir='...' save_dir='...' device='cuda:0' Run sweep for planktivore data
load-i2mapbulk data='data' Load i2MAP bulk data
download-i2mapbulk-unlabeled Download unlabeled i2MAP bulk data
gen-bio-data image_dir="" Generate training data for bio project
gen-cfe-data Generate training data for CFE project
gen-i2map-data Generate training data for i2MAP project
gen-i2mapbulk-data Generate i2MAP training data from bulk server
gen-uav-data Generate training data for UAV project
gen-stats-csv project='UAV' data='/mnt/ML_SCRATCH/UAV/' Generate training data stats
transcode-i2map Transcode i2MAP videos
--

Related projects

  • aidata -A tool to extract, transform, load and download operations on AI data.
  • sdcat - Sliced Detection and Clustering Analysis Toolkit; a tool to detect and cluster objects in images.
  • deepsea-ai - A tool to train and run object detection and tracking on video at scale in the cloud (AWS).
  • fastapi-yolov5 - A RESTful API for running YOLOv5 object detection models on images either locally or in the cloud (AWS).
  • fastapi-vss - A RESTful API for vector similarity search using foundational models.
  • fastapi-tator - A RESTful API server for bulk operations on a Tator annotation database.

updated: 2025-02-20