Apache Airflow provider for Lexio Rent

airflow-provider-lexio connects Apache Airflow to the Lexio Rent API. Use it to move car and van rental data (fleet, rentals, customers, quotes, payments, maintenance) into a warehouse, a BI tool or an accounting system, on a schedule.

Lexio Rent is rental management software for professional car, van and two-wheeler rental companies: planning, contracts, check-in/check-out inspections, deposits and fleet maintenance.

Works with Airflow 2.9+ and Airflow 3. Built on the lexio-rent Python client.

Installation

pip install airflow-provider-lexio

Connection

The Lexio API needs an API key, created in Lexio under Settings → Developer → API tokens. Keys start with lck_. API access is part of the Business plan, and there is no sandbox: test against a dedicated organization.

Create a connection of type Lexio Rent (id lexio_default by default):

Or with an environment variable:

export AIRFLOW_CONN_LEXIO_DEFAULT='{"conn_type": "lexio", "password": "lck_..."}'

The Test button in the Airflow UI calls GET /organization and shows the organization name.

Usage

from lexio_provider.operators.lexio import LexioListOperator, LexioOperator
from lexio_provider.sensors.lexio import LexioEventSensor

# Whole active fleet, written as JSON Lines
export_fleet = LexioListOperator(
    task_id="export_fleet",
    resource="vehicles",
    filters={"is_archived": False},
    output_path="/data/lexio/vehicles_{{ ds_nodash }}.jsonl",
)

# One operation: GET /rentals/{rentalId}
get_rental = LexioOperator(
    task_id="get_rental",
    resource="rentals",
    method="get",
    args=["{{ params.rental_id }}"],
)

# Wait for new or changed rentals
new_rentals = LexioEventSensor(
    task_id="wait_for_rentals",
    event_types=["rental.created", "rental.updated"],
    mode="reschedule",
    poke_interval=60,
)

resource and method follow the lexio-rent client: vehicles.list, rentals.get, rentals.pick_up, customers.create, maintenance_records.list, events.list... Query filters are written in snake_case (is_archived=False is sent as isArchived=false); JSON bodies keep the API field names.

Inside a @task, use the hook directly:

from lexio_provider.hooks.lexio import LexioHook

hook = LexioHook()
for rental in hook.iter_all("rentals", status="RESERVED,IN_PROGRESS"):
    ...

A complete DAG (event sensor, then re-read of the changed rentals, then a fleet export) is in example_dags/lexio_rentals_sync.py.

How the event sensor works

• First run: the feed starts at start="LATEST" (now), or "EARLIEST" (the last 29 days).
• Each poke reads every page from the stored cursor and saves the new cursor in the Variable lexio_events_cursor__<conn id> (configurable with cursor_variable).
• When at least one event matches, the sensor succeeds and returns the events through XCom. Events are thin (id, type, occurredAt, resource.id): read the rental again for its current state.
• The cursor moves forward on every poke, so delivery to downstream tasks is at most once. Cursors expire after 30 days (410 CURSOR_EXPIRED); delete the Variable to start again.

Retries, idempotency and errors

The underlying client retries 429 and 5xx responses on reads and on idempotent writes, honouring Retry-After, and sends an Idempotency-Key on writes that need one, so an Airflow retry never books a vehicle twice. API errors are raised as typed exceptions (NotFoundError, ConflictError, RateLimitError...) with the Lexio code, detail and request_id, which show up in the task log.

Development

pip install -e ".[test]"
pytest

Tests use a mocked HTTP transport; they need no API key.

About

This provider is maintained by the team behind Lexio Rent, car rental management software. A typical pipeline reconciles rental deposits in the warehouse; for the paperwork side, Lexio also publishes a free security deposit refund statement generator (in French) that itemises deductions when a vehicle is returned.

• API documentation: https://docs.lexio.rent
• OpenAPI specification: https://docs.lexio.rent/openapi.json
• Python client: https://github.com/lexio-rent-git/lexio-python
• Contact: contact@lexio.rent

MIT License.