Add an existing asset to a new dandiset

add_asset_to_dandiset.py

from dandi.dandiapi import DandiAPIClient
from dandischema.models import Resource, RelationType
from getpass import getpass
import pandas as  pd
import json

token = getpass() # Enter dandi api token when prompted

df = pd.read_csv("dandi_assets_l1.csv")

da = DandiAPIClient(token=token)

# The new dandiset to write to
ds = da.get_dandiset('123456') # replace with new dandiset id

# post for one asset
for row in df.iterrows():
    print(f"processing row: {row[0]}")
    # get asset
    asset = da.get_asset(row[1].dandi_asset_id)

    asset_meta = asset.get_metadata()
    # connect asset to old asset
    asset_meta.sameAs = [asset_meta.id.replace('dandiasset:', 'http://dandiarchive.org/asset/')]
    
    # create payload for post
    data = {
      "metadata": json.dumps(asset_meta.json_dict()),
      "blob_id": asset.blob,
    }
    # this will generate an exception if the path already exists
    out = da.post(path=ds.api_path + 'versions/draft/assets/', data=data)

# Add old dandisets as sources of the current dandiset in the related resource section
ds_meta = ds.get_metadata()
resources = ds_meta.relatedResource or []
for url in df.dandiset_url.unique():
    ds_old = da.get_dandiset(url.split('/')[-1])
    resources.append(Resource(url=url,
                              name=ds_old.get_metadata().name,
                              relation=RelationType.IsDerivedFrom
                             )
                    )
ds_meta.relatedResource = resources
ds.set_metadata(ds_meta)