콘솔 사용

지원되는 지역에서 콘솔을 사용하여 오브젝트를 추가하면 Aspera Connect 클라이언트를 설치하는 옵션이 프롬프트됩니다. 이 브라우저 플러그인은 파일 또는 폴더를 업로드하기 위한 Aspera 고속 전송을 제공합니다.

Aspera Transfer SDK 사용

1. IBM API 허브에서 Aspera Transfer SDK 를 다운로드하십시오. SDK는 2진 (전송 요청을 청취하기 위한 명령행 유틸리티 및 디먼), 구성 파일 및 언어 특정 커넥터의 콜렉션입니다.
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()