Utilización de la consola

Si añade objetos mediante la consola en una región soportada, se le solicita una opción para instalar el cliente de Aspera Connect. Este plugin de navegador proporciona transferencia de alta velocidad de Aspera para cargar archivos o carpetas.

Utilización del Aspera Transfer SDK

1. Descargue el Aspera Transfer SDK desde IBM API Hub. El SDK es una colección de binarios (programas de utilidad de línea de mandatos y un daemon para escuchar solicitudes de transferencia), archivos de configuración y conectores específicos del idioma.
2. Instale las dependencias grpc desde el gestor de paquetes adecuado (pip, maven, gem, etc.).
3. Inicie el daemon e importe los archivos de conector de lenguaje de programación relevantes al proyecto.
4. Cree una instancia de un cliente Aspera pasándole el puerto local utilizado por el daemon.
5. Cree un transfer_spec que contenga toda la información necesaria para la transferencia:
   1. Información de icos :
      1. Clave de API
      2. ID de instancia de servicio
      3. Punto final de destino
      4. Nombre de grupo
      5. Dirección de transferencia
      6. Host remoto (lo encuentra enviando una solicitud GET a un grupo con un parámetro de consulta ?faspConnectionInfo )
      7. Activos para transferencia (básicamente un conjunto de vías de acceso de archivo)
6. Pase la especificación de transferencia y la información de configuración a una solicitud de transferencia.

A continuación se muestra un ejemplo que utiliza 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()