Migration Guide

# Example migration script for Python
# This script copies models, twins, and relationships from Azure Digital Twins to AgeDigitalTwins

from azure.identity import DefaultAzureCredential
from azure.digitaltwins.core import DigitalTwinsClient
import requests
import json

# Azure Digital Twins configuration
adt_url = "https://your-adt-instance.api.eus.digitaltwins.azure.net"
adt_client = DigitalTwinsClient(adt_url, DefaultAzureCredential())

# AgeDigitalTwins configuration
age_base_url = "https://your-resource-id.api.graph.konnektr.io"
age_headers = {"Authorization": "Bearer your-token"}

# Copy models
def copy_models():
    models = adt_client.list_models(include_model_definition=True)
    for model in models:
        response = requests.post(f"{age_base_url}/models", 
                               json=model.serialize(), 
                               headers=age_headers)
        print(f"Copied model: {model.id}")

# Copy twins
def copy_twins():
    query = "SELECT * FROM digitaltwins"
    twins = adt_client.query_twins(query)
    for twin in twins:
        response = requests.put(f"{age_base_url}/digitaltwins/{twin['$dtId']}", 
                              json=twin, 
                              headers=age_headers)
        print(f"Copied twin: {twin['$dtId']}")

# Copy relationships
def copy_relationships():
    query = "SELECT * FROM relationships"
    relationships = adt_client.query_twins(query)
    for rel in relationships:
        response = requests.put(f"{age_base_url}/digitaltwins/{rel['$sourceId']}/relationships/{rel['$relationshipId']}", 
                              json=rel, 
                              headers=age_headers)
        print(f"Copied relationship: {rel['$relationshipId']}")

if __name__ == "__main__":
    copy_models()
    copy_twins()
    copy_relationships()

// Example migration script for C#
using Azure.Core;
using Azure.DigitalTwins.Core;
using Azure.Identity;
using System.Text.Json;

public class AdtMigration
{
    private readonly DigitalTwinsClient adtClient;
    private readonly HttpClient ageClient;
    
    public AdtMigration()
    {
        var credential = new DefaultAzureCredential();
        adtClient = new DigitalTwinsClient(
            new Uri("https://your-adt-instance.api.eus.digitaltwins.azure.net"), 
            credential);
            
        ageClient = new HttpClient();
        ageClient.BaseAddress = new Uri("https://your-resource-id.api.graph.konnektr.io/");
        ageClient.DefaultRequestHeaders.Add("Authorization", "Bearer your-token");
    }
    
    public async Task CopyModelsAsync()
    {
        var options = new GetModelsOptions { IncludeModelDefinition = true };
        await foreach (var model in adtClient.GetModelsAsync(options))
        {
            var json = JsonSerializer.Serialize(model);
            var content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
            await ageClient.PostAsync("models", content);
            Console.WriteLine($"Copied model: {model.Id}");
        }
    }
    
    public async Task CopyTwinsAsync()
    {
        var query = "SELECT * FROM digitaltwins";
        await foreach (var twin in adtClient.QueryAsync<object>(query))
        {
            var json = JsonSerializer.Serialize(twin);
            var content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
            await ageClient.PutAsync($"digitaltwins/{((dynamic)twin).Id}", content);
            Console.WriteLine($"Copied twin: {((dynamic)twin).Id}");
        }
    }
    
    public async Task CopyRelationshipsAsync()
    {
        var query = "SELECT * FROM relationships";
        await foreach (var rel in adtClient.QueryAsync<object>(query))
        {
            var sourceId = ((dynamic)rel).sourceId;
            var relationshipId = ((dynamic)rel).relationshipId;
            var json = JsonSerializer.Serialize(rel);
            var content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
            await ageClient.PutAsync($"digitaltwins/{sourceId}/relationships/{relationshipId}", content);
            Console.WriteLine($"Copied relationship: {relationshipId}");
        }
    }
}

// Example migration script for JavaScript
const { DigitalTwinsClient } = require('@azure/digital-twins-core');
const { DefaultAzureCredential } = require('@azure/identity');
const axios = require('axios');

// Azure Digital Twins configuration
const adtUrl = 'https://your-adt-instance.api.eus.digitaltwins.azure.net';
const credential = new DefaultAzureCredential();
const adtClient = new DigitalTwinsClient(adtUrl, credential);

// AgeDigitalTwins configuration
const ageBaseUrl = 'https://your-resource-id.api.graph.konnektr.io';
const ageHeaders = { 'Authorization': 'Bearer your-token' };

async function copyModels() {
    const models = adtClient.listModels({ includeModelDefinition: true });
    for await (const model of models) {
        await axios.post(`${ageBaseUrl}/models`, model, { headers: ageHeaders });
        console.log(`Copied model: ${model.id}`);
    }
}

async function copyTwins() {
    const query = 'SELECT * FROM digitaltwins';
    const twins = adtClient.queryTwins(query);
    for await (const twin of twins) {
        await axios.put(`${ageBaseUrl}/digitaltwins/${twin.$dtId}`, twin, 
                       { headers: ageHeaders });
        console.log(`Copied twin: ${twin.$dtId}`);
    }
}

async function copyRelationships() {
    const query = 'SELECT * FROM relationships';
    const relationships = adtClient.queryTwins(query);
    for await (const rel of relationships) {
        await axios.put(`${ageBaseUrl}/digitaltwins/${rel.$sourceId}/relationships/${rel.$relationshipId}`, 
                       rel, { headers: ageHeaders });
        console.log(`Copied relationship: ${rel.$relationshipId}`);
    }
}

async function main() {
    await copyModels();
    await copyTwins();
    await copyRelationships();
}

main().catch(console.error);