Utilizzo della console

Se aggiungi degli oggetti utilizzando la console in una regione supportata, ti viene presentata l'opzione di installare il client Aspera Connect. Questo plugin del browser fornisce il trasferimento ad alta velocità Aspera per caricare i file o le cartelle.

Utilizzo di Aspera Transfer SDK

1. Scarica Aspera Transfer SDK da IBM API Hub. L'SDK è una raccolta di file binari (programmi di utilità della riga di comando e un daemon per ascoltare le richieste di trasferimento), file di configurazione e connettori specifici della lingua.
2. Installa le dipendenze grpc dal gestore pacchetti appropriato (pip, maven, gem, ecc.).
3. Avviare il daemon e importare i relativi file del connettore del linguaggio di programmazione nel progetto.
4. Creare un'istanza di un client Aspera passandolo alla porta locale utilizzata dal daemon.
5. Creare un transfer_spec contenente tutte le informazioni necessarie per il trasferimento:
   1. icos Informazioni:
      1. Chiave API
      2. ID istanza del servizio
      3. Endpoint di destinazione
      4. Nome bucket
      5. Direzione trasferimento
      6. Host remoto (lo trovi inviando una richiesta GET a un bucket con un parametro di query ?faspConnectionInfo )
      7. Asset per trasferimento (fondamentalmente una serie di percorsi file)
6. Passare la specifica di trasferimento e le informazioni di configurazione a una richiesta di trasferimento.

Di seguito è riportato un esempio che utilizza 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()