The main goal is to create a class within the vehicle-side library that can be used to publish RabbitMQ messages to a subscriber running on GCS.
How It Should Work
On vehicle-side, the code for sending telemetry would probably look something like this:
# `integration` is the supposed name of the library
from integration.Telemetry import TelemetryRabbitMQ
from integration.Types import Telemetry
# Initializing a telemetry object should initiate a connection towards the RabbitMQ broker server
# We use ERU as an example here, but this should work with any vehicle.
telemetry = TelemetryRabbitMQ(vehicleName="ERU")
while True:
data = Telemetry(
# Parameters for Telemetry type goes here
)
telemetry.publish(vehicleData=data)
Your class implementation should abstract the process of connecting and publishing messages to RabbitMQ to 2-3 operations max.
Also a quick reminder of how the Vehicle-to-GCS integration model looks like.
Issue Goal
The main goal is to create a class within the vehicle-side library that can be used to publish RabbitMQ messages to a subscriber running on GCS.
How It Should Work
On vehicle-side, the code for sending telemetry would probably look something like this:
Your class implementation should abstract the process of connecting and publishing messages to RabbitMQ to 2-3 operations max.
Also a quick reminder of how the Vehicle-to-GCS integration model looks like.