Account transfer from Regular to Key Pair

In Domo, there isn't a built-in feature to directly mass transfer datasets from one connector to another. You would need to come up with a process. You could try automating the process through Domo's API. But I think I would attempt it in Python.

Authenticate

import requests


# Domo API credentials

client_id = 'YOUR_CLIENT_ID'

client_secret = 'YOUR_CLIENT_SECRET'

auth_url = 'https://api.domo.com/oauth/token?grant_type=client_credentials&scope=data'


# Get access token

response = requests.get(auth_url, auth=(client_id, client_secret))

access_token = response.json().get('access_token')

headers = {

    'Authorization': f'Bearer {access_token}',

    'Content-Type': 'application/json'

}

List Datasets that use the old connector

# Get list of datasets

datasets_url = 'https://api.domo.com/v1/datasets'

params = {'limit': 50}  # Adjust the limit as needed

datasets = requests.get(datasets_url, headers=headers, params=params).json()


# Filter datasets by Snowflake connection (you may need to add additional filtering logic)

old_connection_id = 'OLD_CONNECTION_ID'

datasets_to_migrate = [ds for ds in datasets if ds['dataSource']['id'] == old_connection_id]

Recreate datasets with new connector

new_connection_id = 'NEW_KEY_PAIR_CONNECTION_ID'


for dataset in datasets_to_migrate:

    new_dataset_payload = {

        'name': dataset['name'],

        'dataSource': {

            'id': new_connection_id

        },

        'schema': dataset['schema'],

        'sql': dataset['sql']  # Adjust based on how the query is stored

    }


    new_dataset_url = 'https://api.domo.com/v1/datasets'

    response = requests.post(new_dataset_url, headers=headers, json=new_dataset_payload)


    if response.status_code == 201:

        print(f"Dataset {dataset['name']} recreated successfully.")

    else:

        print(f"Failed to create dataset {dataset['name']}: {response.text}")

Replace references in dataflows and dashboards

# Example to replace dataset references (conceptual)

def update_references(old_dataset_id, new_dataset_id):

    # Get all dataflows using the old dataset

    dataflows_url = f'https://api.domo.com/v1/dataflows?includeDataSourceId={old_dataset_id}'

    dataflows = requests.get(dataflows_url, headers=headers).json()


    # Update each dataflow to use the new dataset

    for dataflow in dataflows:

        for input_ds in dataflow['inputs']:

            if input_ds['id'] == old_dataset_id:

                input_ds['id'] = new_dataset_id

        # Send the updated dataflow back to Domo

        update_url = f'https://api.domo.com/v1/dataflows/{dataflow["id"]}'

        response = requests.put(update_url, headers=headers, json=dataflow)

        if response.status_code == 200:

            print(f"Dataflow {dataflow['name']} updated successfully.")

        else:

            print(f"Failed to update dataflow {dataflow['name']}: {response.text}")