rdstation-api-helper 1.1.0

ETL module for RD Station API database-optimized DataFrame processing

RD Station API Helper

A Python library for interacting with the RD Station API, providing ORM models, authentication, segmentation, contact, and event retrieval, as well as batch and parallel data fetching utilities.

Features

• RD Station API v2 support: Query segmentations, contacts, leads, and conversion events
• ORM Models: SQLAlchemy models for RD Station entities (Segmentation, Contact, Lead, etc.)
• Batch & Parallel Fetching: Utilities for efficient data extraction
• Robust Error Handling: Comprehensive error handling and retry logic
• Logging & Config Utilities: Easy configuration and logging
• Type Hints: Full type hint support for better IDE experience

Installation

pip install rdstation-api-helper

Quick Start

1. Set up credentials

Create a secrets/rdstation_secret.json file with your RD Station API credentials:

{
  "RDSTATION_CLIENT_ID": "YOUR_CLIENT_ID",
  "RDSTATION_CLIENT_SECRET": "YOUR_CLIENT_SECRET",
  "RDSTATION_REFRESH_TOKEN": "YOUR_REFRESH_TOKEN"
}

2. Basic usage

from rdstation_api_helper import RDStationAPI

# Initialize API client (loads credentials from environment or .env)
client = RDStationAPI()

# Fetch all segmentations
segmentations = client.get_segmentations()

# Fetch contacts for each segmentation
contacts = client.get_segmentation_contacts("segmentations_id")

# Fetch contact data for a specific UUID
status_code, contact_data = client.get_contact_data("contact_uuid")

# Fetch conversion events for a contact
status_code, events = client.get_contact_events("some-contact_uuid")

ORM Models

The package provides SQLAlchemy ORM models for RD Station entities, which can be used for database integration.

• Segmentation
• SegmentationContact
• Contact
• ContactFunnelStatus
• ConversionEvents
• Lead

Examples

Check the examples/ directory for comprehensive usage examples:

• basic_usage.py - Simple report extraction

Parallel & Batch Fetching

The library provides a parallel_decorator utility to easily parallelize API calls for batch data fetching. This is used in the following methods of RDStationAPI:

• get_contact_data_parallel(uuids: list[str])
• get_contact_events_parallel(uuids: list[str])
• get_contact_funnel_status_parallel(uuids: list[str])

These methods accept a list of UUIDs and fetch the corresponding data in parallel, handling rate limits and transient errors automatically. The decorator coordinates retries for 429/5xx/network errors and ensures each result is tagged with its UUID.

Usage Example

from rdstation_api_helper import RDStationAPI

client = RDStationAPI()
uuids = ["uuid1", "uuid2", "uuid3"]

# Fetch contact data in parallel
_, contact_results = client.get_contact_data_parallel(uuids)

# Fetch contact events in parallel
_, events_results = client.get_contact_events_parallel(uuids)

# Fetch funnel status in parallel
_, funnel_results = client.get_contact_funnel_status_parallel(uuids)

print(contact_results)
print(events_results)
print(funnel_results)

Features:

• Automatic parallelization with configurable worker count
• Handles 429/5xx/network errors with coordinated retries
• Appends the UUID to each result for traceability

See the rdstation_api_helper/utils.py source for details.

Requirements

• Python 3.10-3.12
• pandas >= 2.0.0
• python-dotenv >= 1.0.0
• requests >= 2.32.4
• tqdm >= 4.65.0

License

This project is licensed under the GPL License. See LICENSE file for details.

Contributing

Contributions are welcome! Please feel free to submit a Pull Request.