Data Pipeline Hub
Manage data sources, connectors, and ingestion pipelines across your Energy Atlas deployment.
↑ 8%
8
Connected Sources
21
Active Tables
7 schemas
↑ 12%
24,456
Rows Ingested Today
7
Active Sources
1 failed
Quick Actions
Jump into any integration workflow
New API Source→
Connect Database→
Import File→
Provision Infra→
Recent Sync Activity
Live data ingestion status across all sources
API Connector
Connect to third-party REST APIs for automated data ingestion.
1,440
rows today
120ms
avg latency
Target
raw_iex.day_ahead_prices
Last Sync
8:15 AM
Auth
API Key
288
rows today
450ms
avg latency
Target
raw_demand.state_demand
Last Sync
8:30 AM
Auth
Bearer Token
8,760
rows today
200ms
avg latency
Target
raw_weather.hourly_forecast
Last Sync
8:00 AM
Auth
API Key
0
rows today
-
avg latency
Target
raw_pxil.market_prices
Last Sync
Failed 6:00 AM
Auth
API Key
12,480
rows today
340ms
avg latency
Target
raw_merit.generator_data
Last Sync
7:45 AM
Auth
Bearer Token
DB Connector
Connect to PostgreSQL, MySQL, BigQuery, and other databases.
Connectivity Mode
Existing Connections
12
schemas
47
tables
4
schemas
18
tables
0
schemas
0
tables
Import Wizard
Upload CSV, Excel, Parquet, or JSON files to import into the database.
Infra Provisioner
Provision managed databases across cloud providers with Terraform.
Google Cloud
Cloud SQL, BigQuery, AlloyDB
Amazon Web Services
RDS, Aurora, Redshift
Microsoft Azure
Azure SQL, Azure PostgreSQL
Terraform Plan Preview
+ google_sql_database_instance.energy_atlas
name = "aion-energy-atlas-prod"
database_version = "POSTGRES_16"
region = "asia-south1"
tier = "db-n1-standard-2"
disk_size = 100
availability_type = "REGIONAL"
deletion_protection = true
+ google_sql_database.energy_atlas_db
name = "energy_atlas"
instance = google_sql_database_instance.energy_atlas.name
+ google_sql_user.flux_service
name = "flux_service"
type = "BUILT_IN"
Plan: 3 to add, 0 to change, 0 to destroy.Schema Registry
Central metadata catalog of all schemas, tables, and data lineage.
raw_iex
IEX market exchange data
2.1M
total rows
4
tables
day_ahead_prices
rtm_prices
tam_contracts
green_certificates
raw_weather
Weather forecast and actuals
5.8M
total rows
3
tables
hourly_forecast
daily_actuals
station_metadata
raw_demand
State-level demand and SLDC data
1.8M
total rows
3
tables
state_demand
block_schedule
frequency_profile
energy_atlas_market
Market data — IEX, PXIL, NSE derivatives
340K
total rows
4
tables
futures_daily
spot_reference_rate
futures_contract
futures_product
tenant_kptcl
KPTCL-specific isolated data
450K
total rows
3
tables
demand_schedule
dsm_penalties
revision_history
Settings
Configure FLUX pipeline hub preferences.
API Configuration
Backend service connection
Notifications
Alert preferences
Sync failures
Alert when a sync operation fails
Schema changes
Detect upstream schema drift
Row count anomalies
Alert on unusual ingestion volumes
Latency spikes
Alert when source latency exceeds threshold