Verwendung der Konsole

Wenn Sie Objekte über die Konsole in einer unterstützten Region hinzufügen, dann werden Sie über eine entsprechende Option aufgefordert, den Aspera Connect-Client zu installieren. Dieses Browser-Plug-in stellt die Funktion für die Aspera-Hochgeschwindigkeitsübertragung zum Hochladen von Dateien oder Ordnern bereit.

Aspera Transfer SDK verwenden

1. Laden Sie das Aspera Transfer SDK von IBM API Hub herunter. Das SDK ist eine Sammlung von Binärdateien (Befehlszeilendienstprogramme und ein Dämon zum Überwachen von Übertragungsanforderungen), Konfigurationsdateien und sprachspezifischen Connectors.
2. Installieren Sie die grpc-Abhängigkeiten vom entsprechenden Paketmanager (pip, maven, gem usw.).
3. Starten Sie den Dämon und importieren Sie die relevanten Dateien des Programmiersprachenconnectors in Ihr Projekt.
4. Instanziieren Sie einen Aspera-Client, indem Sie den lokalen Port übergeben, der vom Dämon verwendet wird.
5. Erstellen Sie eine transfer_spec mit allen für die Übertragung erforderlichen Informationen:
   1. icos INFORMATION:
      1. API-Schlüssel
      2. Die Serviceinstanz-ID
      3. Zielendpunkt
      4. Gruppierungsname
      5. Übertragungsrichtung
      6. Ferner Host (Sie finden dies durch Senden einer GET-Anforderung an ein Bucket mit einem Abfrageparameter ?faspConnectionInfo )
      7. Assets für Übertragung (im Grunde eine Gruppe von Dateipfaden)
6. Übergeben Sie die Transferspezifikation und die Konfigurationsdaten an eine Transferanforderung.

Das folgende Beispiel zeigt die Verwendung von 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()