Quickstart: Azure to AWS

export ADAPTER_BLOB_ENDPOINT="https://adapter.example.test/origin-account"
export ORIGIN_ACCOUNT_NAME="origin-account"
export ORIGIN_ACCOUNT_KEY="use-your-test-secret-source"
export ORIGIN_CONTAINER="adapter-smoke-test"
export TARGET_BUCKET="adapter-smoke-test-aws"
export AWS_VERIFY_PROFILE="aws-target-verify"
export AWS_TARGET_REGION="us-east-1"
export TEST_BLOB="quickstart/azure-aws-$(date +%s).txt"

import os
from azure.core.credentials import AzureNamedKeyCredential
from azure.storage.blob import BlobServiceClient, ContentSettings

service = BlobServiceClient(
    account_url=os.environ["ADAPTER_BLOB_ENDPOINT"],
    credential=AzureNamedKeyCredential(
        os.environ["ORIGIN_ACCOUNT_NAME"],
        os.environ["ORIGIN_ACCOUNT_KEY"],
    ),
)
container = service.get_container_client(os.environ["ORIGIN_CONTAINER"])
blob = container.get_blob_client(os.environ["TEST_BLOB"])
expected = b"hello from Blob Storage to S3\n"

blob.upload_blob(
    expected,
    overwrite=True,
    content_settings=ContentSettings(content_type="text/plain"),
)
properties = blob.get_blob_properties()
actual = blob.download_blob().readall()
assert actual == expected
print({"etag": properties.etag, "size": properties.size})

aws s3api head-object \
  --bucket "$TARGET_BUCKET" \
  --key "$TEST_BLOB" \
  --profile "$AWS_VERIFY_PROFILE" \
  --region "$AWS_TARGET_REGION"

aws s3api get-object \
  --bucket "$TARGET_BUCKET" \
  --key "$TEST_BLOB" \
  --profile "$AWS_VERIFY_PROFILE" \
  --region "$AWS_TARGET_REGION" \
  /tmp/cloud-adapter-target.txt

printf 'hello from Blob Storage to S3\n' | cmp - /tmp/cloud-adapter-target.txt

blob.delete_blob()