Import and convert

Parse and migrate assets from Fivetran, dbt, Matillion, Informatica, Alteryx, SSIS, and run bulk connection or pipeline creation. Use dry-run to preview changes, then inspect history and type mapping references.

Send Authorization: Bearer <api_key>. Large uploads may require multipart/form-data; examples below use JSON metadata where the API accepts structured bodies. See Authentication.

Base URL

https://api.planasonix.com

Discover Fivetran connectors

POST /api/convert/fivetran/discover

Request body

{
  "api_key": "ft_xxxxxxxxxxxxxxxx",
  "group_id": "iodine_magnesium",
  "include_paused": false
}

Response 200 OK

{
  "data": {
    "group_id": "iodine_magnesium",
    "connectors": [
      {
        "id": "connector_saas_salesforce",
        "service": "salesforce",
        "schema": "salesforce_raw",
        "status": "connected",
        "sync_frequency_minutes": 360
      },
      {
        "id": "connector_warehouse_snowflake_dest",
        "service": "snowflake_db",
        "schema": "fivetran_snowflake",
        "status": "connected",
        "sync_frequency_minutes": 60
      }
    ]
  }
}

Parse dbt project

POST /api/convert/dbt/parse

Typically invoked with an archive upload; this example shows a remote Git reference. Request body

{
  "source": {
    "type": "git",
    "url": "https://github.com/acme-analytics/dbt-analytics",
    "ref": "v1.4.2",
    "path": "."
  },
  "target_profile": "snowflake_prod"
}

Response 202 Accepted

{
  "data": {
    "parse_job_id": "cvjob_01jq8dbt01",
    "status": "queued",
    "estimated_models": 42
  }
}

Parse Matillion export

POST /api/convert/matillion/parse

Request body

{
  "artifact": {
    "type": "upload",
    "filename": "matillion_export.zip",
    "content_type": "application/zip"
  },
  "options": {
    "default_warehouse": "COMPUTE_WH",
    "map_orchestration_to": "pipeline_control_flow"
  }
}

Response 202 Accepted

{
  "data": {
    "parse_job_id": "cvjob_01jq8mat01",
    "status": "queued"
  }
}

Parse Informatica mapping

POST /api/convert/informatica/parse

Request body

{
  "artifact": {
    "type": "upload",
    "filename": "m_customer_dim.xml",
    "content_type": "application/xml"
  },
  "repository_version": "10.5"
}

Response 200 OK (synchronous small file)

{
  "data": {
    "parse_job_id": "cvjob_01jq8inf01",
    "status": "succeeded",
    "mappings_detected": 1,
    "pipelines_preview": [
      {
        "suggested_name": "customer_dim_scd2",
        "source_systems": ["oracle_hr"],
        "target_tables": ["dw.dim_customer"]
      }
    ]
  }
}

Parse Alteryx workflow

POST /api/convert/alteryx/parse

Request body

{
  "artifact": {
    "type": "upload",
    "filename": "weekly_kpi_prep.yxmd",
    "content_type": "application/xml"
  }
}

Response 202 Accepted

{
  "data": {
    "parse_job_id": "cvjob_01jq8alt01",
    "status": "queued"
  }
}

Parse SSIS package

POST /api/convert/ssis/parse

Request body

{
  "artifact": {
    "type": "upload",
    "filename": "load_warehouse.dtsx",
    "content_type": "application/xml"
  },
  "sql_server_version": "2019"
}

Response 202 Accepted

{
  "data": {
    "parse_job_id": "cvjob_01jq8ssis01",
    "status": "queued"
  }
}

Bulk create connections

POST /api/convert/connections/bulk

Request body

{
  "dry_run": false,
  "connections": [
    {
      "name": "snowflake_prod",
      "type": "snowflake",
      "parameters": {
        "account": "xy12345.us-east-1",
        "database": "ANALYTICS",
        "warehouse": "ETL_WH",
        "role": "LOADER"
      },
      "credential_ref": "vault://kv/snowflake_prod_user"
    },
    {
      "name": "salesforce_prod",
      "type": "salesforce",
      "parameters": {
        "auth": "oauth_refresh_token"
      },
      "credential_ref": "vault://kv/sf_prod_oauth"
    }
  ]
}

Response 200 OK

{
  "data": {
    "created": [
      { "name": "snowflake_prod", "id": "conn_01jq8sf01" },
      { "name": "salesforce_prod", "id": "conn_01jq8sf02" }
    ],
    "failed": [],
    "dry_run": false
  }
}

Bulk create pipelines

POST /api/convert/pipelines/bulk

Request body

{
  "dry_run": false,
  "pipelines": [
    {
      "name": "staging_shopify_orders",
      "definition": {
        "format": "planasonix_v1",
        "document": {
          "nodes": [],
          "edges": []
        }
      },
      "environment": "production"
    }
  ]
}

Response 200 OK

{
  "data": {
    "created": [
      { "name": "staging_shopify_orders", "id": "pl_01jq8new01" }
    ],
    "failed": [],
    "dry_run": false
  }
}

Preview conversion (dry run)

POST /api/convert/dry-run

Request body

{
  "source": {
    "type": "matillion",
    "parse_job_id": "cvjob_01jq8mat01"
  },
  "options": {
    "include_connections": true,
    "naming_prefix": "migrated_"
  }
}

Response 200 OK

{
  "data": {
    "dry_run": true,
    "would_create": {
      "connections": 2,
      "pipelines": 5,
      "schedules": 5
    },
    "warnings": [
      {
        "code": "unsupported_transform",
        "message": "Matillion \"Rank\" component mapped to approximate sort window"
      }
    ],
    "blocking_errors": []
  }
}

Get conversion history

GET /api/convert/history

Query parameters

Parameter	Description
`limit`, `cursor`	Pagination
`source_type`	Filter by `fivetran`, `dbt`, etc.

Response 200 OK

{
  "data": [
    {
      "id": "cv_01jq8hist01",
      "source_type": "dbt",
      "status": "succeeded",
      "initiated_by": "usr_01jq8me",
      "started_at": "2025-03-20T10:00:00Z",
      "finished_at": "2025-03-20T10:06:22Z",
      "summary": {
        "pipelines_created": 38,
        "connections_created": 1
      }
    }
  ],
  "meta": {
    "page": { "limit": 20, "cursor": null }
  }
}

Type mapping reference

GET /api/convert/type-map

Query parameters

Parameter	Description
`source`	Source platform (for example `informatica`)
`target`	Warehouse or runtime (for example `snowflake`)

Response 200 OK

{
  "data": {
    "source": "informatica",
    "target": "snowflake",
    "mappings": [
      {
        "source_type": "decimal(p,s)",
        "target_type": "NUMBER(p,s)",
        "notes": "Precision and scale preserved when p <= 38"
      },
      {
        "source_type": "nstring",
        "target_type": "VARCHAR",
        "notes": "Length inferred from column metadata when available"
      },
      {
        "source_type": "datetime",
        "target_type": "TIMESTAMP_NTZ",
        "notes": "Timezone normalization applied per connection setting"
      }
    ],
    "version": "2025-03-01"
  }
}

End-to-end migration overview.

Convert: dbt

dbt-specific guidance.

Overview

Data platform

Orchestration

Integration

Governance

Iceberg Catalog

Platform

Import and convert

Base URL

Discover Fivetran connectors

Parse dbt project

Parse Matillion export

Parse Informatica mapping

Parse Alteryx workflow

Parse SSIS package

Bulk create connections

Bulk create pipelines

Preview conversion (dry run)

Get conversion history

Type mapping reference