Sift Docs

# Define the schema of your telemetry
config = TelemetryConfig(asset_name="MarsRover0", flows=[
  FlowConfig(name="velocity-reading", channels=[
    ChannelConfig(
      component="mainmotor",
      name="velocity",
      data_type=ChannelDataType.DOUBLE,
      unit="m/s",
    )
  ])
])
 
# Connect to Sift
with use_sift_channel(SiftChannelConfig(sift_url, api_key)) as grpc_channel:
    # Create an ingestion service
    ingestion_service = IngestionService(grpc_channel, config)
 
    # Stream sensor data
    for timestamp, velocity in data_source():
      ingestion_service.ingest_flows({
          "flow_name": "velocity-reading",
          "timestamp": timestamp,
          "channel_values": [double_value(velocity)],
      })