コンソールの使用

サポートされる地域内でコンソールを使用してオブジェクトを追加すると、プロンプトが出され、Aspera Connect クライアントをインストールするオプションが示されます。 このブラウザー・プラグインは、ファイルまたはフォルダーをアップロードするために Aspera 高速転送を提供します。

Aspera Transfer SDK の使用

1. IBM API Hub から Aspera Transfer SDK をダウンロードします。 SDK は、バイナリー (転送要求を listen するコマンド・ライン・ユーティリティーとデーモン)、構成ファイル、および言語固有のコネクターの集合です。
2. 該当するパッケージ・マネージャー (pip、maven、gem など) から grpc 依存関係をインストールします。
3. デーモンを起動し、関連するプログラミング言語コネクター・ファイルをプロジェクトにインポートします。
4. デーモンが使用するローカル・ポートを渡すことにより、 Aspera クライアントをインスタンス化します。
5. 転送に必要なすべての情報を含む transfer_spec を作成します。
   1. icos 情報:
      1. API キー
      2. サービス・インスタンス ID
      3. ターゲット・エンドポイント
      4. バケット名
      5. 転送方向
      6. リモート・ホスト (これは、 ?faspConnectionInfo 照会パラメーターを使用して GET 要求をバケットに送信することによって検出されます)
      7. 転送する資産 (基本的にはファイル・パスのセット)
6. 転送仕様と構成情報を転送要求に渡します。

以下に、 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()