Utilisation de la console

Si vous ajoutez des objets en utilisant la console dans une région prise en charge, vous êtes invité à installer le client Aspera Connect. Ce plug-in de navigateur offre le transfert haut débit Aspera pour télécharger des fichiers et des dossiers.

Utilisation du Aspera Transfer SDK

1. Téléchargez le logiciel Aspera Transfer SDK à partir d' IBM API Hub. Le SDK est une collection de fichiers binaires (utilitaires de ligne de commande et démon pour écouter les demandes de transfert), de fichiers de configuration et de connecteurs spécifiques à la langue.
2. Installez les dépendances grpc à partir du gestionnaire de package approprié (pip, maven, gem, etc.).
3. Lancez le démon et importez les fichiers de connecteur de langage de programmation appropriés dans votre projet.
4. Instanciez un client Aspera en lui transmettant le port local utilisé par le démon.
5. Créez un transfer_spec contenant toutes les informations nécessaires au transfert:
   1. icos Informations :
      1. Clé d'API
      2. ID de l'instance de service
      3. Noeud final cible
      4. Nom du compartiment
      5. Sens de transfert
      6. Hôte distant (vous pouvez le trouver en envoyant une demande GET à un compartiment avec un paramètre de requête ?faspConnectionInfo )
      7. Actifs pour le transfert (essentiellement un ensemble de chemins de fichier)
6. Transmettez la spécification de transfert et les informations de configuration à une demande de transfert.

Voici un exemple d'utilisation de Python:

import random
import string

import grpc
import json
import os.path

from urllib3.connectionpool import xrange

import transfer_pb2 as transfer_manager
import transfer_pb2_grpc as transfer_manager_grpc


def run():
    # create a connection to the transfer manager daemon
    client = transfer_manager_grpc.TransferServiceStub(
        grpc.insecure_channel('localhost:55002'))

    # create file
    file_path = generate_source_file()

    # create transfer spec
    transfer_spec = {
        "session_initiation": {
            "icos": {
                "api_key": os.environ.get('IBMCLOUD_API_KEY'),
                "bucket": os.environ.get('IBMCLOUD_BUCKET'),
                "ibm_service_instance_id": os.environ.get('IBMCLOUD_COS_INSTANCE'),
                "ibm_service_endpoint": os.environ.get('IBMCLOUD_COS_ENDPOINT')
            }
        },
        "direction": "send",
        "remote_host": "https://ats-sl-dal.aspera.io:443",
        "title": "strategic",
        "assets": {
            "destination_root": "/aspera/file",
            "paths": [
                {
                    "source": file_path
                }
            ]
        }
    }
    transfer_spec = json.dumps(transfer_spec)

    # create a transfer request
    transfer_request = transfer_manager.TransferRequest(
        transferType=transfer_manager.FILE_REGULAR,
        config=transfer_manager.TransferConfig(),
        transferSpec=transfer_spec)

    # send start transfer request to transfer manager daemon
    transfer_response = client.StartTransfer(transfer_request)
    transfer_id = transfer_response.transferId
    print("transfer started with id {0}".format(transfer_id))

    # monitor transfer status
    for transfer_info in client.MonitorTransfers(
            transfer_manager.RegistrationRequest(
                filters=[transfer_manager.RegistrationFilter(
                    transferId=[transfer_id]
                )])):
        print("transfer info {0}".format(transfer_info))

        # check transfer status in response, and exit if it's done
        status = transfer_info.status
        if status == transfer_manager.FAILED or status == transfer_manager.COMPLETED:
            print("finished {0}".format(status))
            break


def generate_source_file(name='file'):
    with open(name, 'w') as file:
        # file.write('Hello World!')
        file.write(''.join(random.choice(string.ascii_lowercase) for i in xrange(10 ** 10)))
    return os.path.abspath(name)


if __name__ == '__main__':
    run()