Canso - ML Platform
  • 👋Introduction
  • 🏛️Canso Architecture
  • 💻Getting Started
    • 🏁Overview
    • 🌌Provison K8s Clusters
    • 🚢Install Canso Helm Charts
    • 🐍🔗 Canso Python Client & Web App
    • 📊Health Metrics for Features in the Data Plane
  • 💡Feature Store
    • Data Sources
      • Data Spans
    • Data Sinks
    • ML Features
      • Raw ML Batch Feature
      • Derived ML Batch Feature
      • Raw ML Streaming Feature
      • Custom User Defined Function
  • 💡AI Agents
    • Introduction
    • Getting Started
    • Quickstart
    • Use Cases
      • Fraud Analyst Agent
      • Agent with Memory
      • Memory command examples
    • Concepts
      • Task Server
      • Broker
      • Checkpoint DB
      • Conversation History
      • Memory
    • How Tos
      • Update the AI Agent
      • Delete the AI Agent
    • Toolkit
      • SQL Runner
      • Kubernetes Job
      • Text-to-SQL
    • API Documentation
      • Agent
      • Memory
  • 💡Risk
    • Overview
    • Workflows and Rules
    • Real Time Transaction Monitoring
    • API Documentation
  • 💡Fraud Investigation
    • API Documentation
  • 📝Guides
    • Registry
    • Dry Runs for Batch ML Features
    • Deployment
Powered by GitBook
On this page
  • Setting up the Broker
  • Tool Tips

Was this helpful?

  1. 💡AI Agents
  2. Concepts

Broker

PreviousTask ServerNextCheckpoint DB

Last updated 6 months ago

Was this helpful?

Broker is a key component in the Canso AI Agentic System that facilitates orchestration between the AI Agents and the . It acts as an intermediary, receiving tasks from AI Agents and distributing them across task workers for processing.

Note: Currently, only Redis is supported as a message broker. Support for RabbitMQ and Kafka will be added in future releases.

Setting up the Broker

To set up the task server, define a YAML file:

broker:
  type: redis
  name: my-redis

The table below explains the configuration attribues:

Attribute
Description
Example

type

Type of broker

redis

name

Name of the broker instance

agent-task-broker

Run the gru command to to set up the Broker:

gru component setup --cluster-name <cluster-name> --config-file config.yaml

Tool Tips

Go to ⬅️

See ➡️

Learn about ➡️

Explore ➡

Introduction
Task Server
Checkpoint DB
Memory
Canso Task Server
Role of the Broker