Crate mcai_worker_sdk[−][src]
MCAI Worker SDK
This library is an SDK to communicate via message broker with StepFlow. It’s used for every worker as an abstraction. It manage itself requirements, message parsing, direct messaging.
Worker implementation
- Create a Rust project
- Add MCAI Worker SDK as a dependency in Cargo.toml:
mcai_worker_sdk = "^1.0"
- Update the main file with the example provided here to implement MessageEvent trait,
and call the
start_worker
to start the worker itself.
use mcai_worker_sdk::prelude::*; use serde_derive::Deserialize; use schemars::JsonSchema; #[derive(Debug)] struct WorkerNameEvent {} #[derive(Debug, Deserialize, JsonSchema)] struct WorkerParameters {} impl MessageEvent<WorkerParameters> for WorkerNameEvent { fn get_name(&self) -> String {"sample_worker".to_string()} fn get_short_description(&self) -> String {"Short description".to_string()} fn get_description(&self) -> String {"Long description".to_string()} fn get_version(&self) -> Version { Version::new(0, 0, 1) } } static WORKER_NAME_EVENT: WorkerNameEvent = WorkerNameEvent {}; // uncomment it to start the worker // fn main() { // mcai_worker_sdk::start_worker(&WORKER_NAME_EVENT); // }
Runtime configuration
AMQP connection
Variable | Description |
---|---|
AMQP_HOSTNAME | IP or host of AMQP server (default: localhost ) |
AMQP_PORT | AMQP server port (default: 5672 ) |
AMQP_TLS | enable secure connection using AMQPS (default: false , enable with true or 1 or TRUE or True ) |
AMQP_USERNAME | Username used to connect to AMQP server (default: guest ) |
AMQP_PASSWORD | Password used to connect to AMQP server (default: guest ) |
AMQP_VHOST | AMQP virtual host (default: / ) |
AMQP_QUEUE | AMQP queue name used to receive job orders (default: job_undefined ) |
Vault connection
Variable | Description |
---|---|
BACKEND_HOSTNAME | URL used to connect to backend server (default: http://127.0.0.1:4000/api ) |
BACKEND_USERNAME | Username used to connect to backend server |
BACKEND_PASSWORD | Password used to connect to backend server |
Start worker locally
MCAI Worker SDK can be launched locally - without RabbitMQ. It can process some message for different purpose (functional tests, message order examples, etc.).
To start worker in this mode, setup the environment variable SOURCE_ORDERS
with path(s) to json orders.
It can take multiple orders, joined with :
on unix platform, ;
on windows os.
Examples:
RUST_LOG=info SOURCE_ORDERS=./examples/success_order.json:./examples/error_order.json cargo run --example worker
Re-exports
pub use message::publish_job_progression; | |
pub use message_event::MessageEvent; | |
pub use parameter::container::ParametersContainer; |
Modules
client | |
config | |
job | Module to manage Job |
message | |
message_event | |
message_exchange | Connectors between message brokers and processors |
parameter | |
prelude | |
processor | |
worker | Module to manage the worker (configuration and status information) |
Enums
MessageError | Internal error status to manage process errors |
Type Definitions
McaiChannel | Exposed Channel type |
Result |