azure - 如何从azure获取blob

Question

我正在尝试通过官方 azure-sdk-for-go 从 Go 中的 Azure Blob 存储下载一些数据。

为了设置我的开发环境，我已通过 az login 成功登录。我已经验证可以通过 CLI 访问该 blob:

az storage blob download --container-name [container-name] --name [blob-name] --account-name [storage-account-name] -f out.txt

这按预期工作。为了获取文件 unsing go，我使用以下代码片段(作为重现器):

func getBlob(account, container, object string) ([]byte, error) {
        blobPath := fmt.Sprintf("https://%s.blob.core.windows.net/%s/%s", uri.Host, container, object)
        ctx := context.Background()

        credential, err := azidentity.NewDefaultAzureCredential(nil)
        if err != nil {
            return []byte{}, err
        }

        blobClient, err := azblob.NewBlockBlobClient(blobPath, credential, nil)
        if err != nil {
            return []byte{}, err
        }

        get, err := blobClient.Download(ctx, nil)
        if err != nil {
            return []byte{}, err
        }

        downloadedData := &bytes.Buffer{}
        reader := get.Body(&azblob.RetryReaderOptions{})
        _, err = downloadedData.ReadFrom(reader)
        if err != nil {
            return []byte{}, err
        }
        err = reader.Close()
        if err != nil {
            return []byte{}, err
        }
        data = downloadedData.Bytes()
        return data, nil
}

通过az login登录，我希望azidentity.NewDefaultAzureCredential(nil)使用此 session /证书(请参阅 https://learn.microsoft.com/en-us/azure/developer/go/azure-sdk-authentication?tabs=bash#-option-3-sign-in-with-azure-cli )，但这似乎并非没有按预期工作。我得到的错误如下:

===== RESPONSE ERROR (ErrorCode=AuthorizationPermissionMismatch) =====
Description=This request is not authorized to perform this operation using this permission.
RequestId:b078ec61-xxxx-xxxx-xxxx-604682000000
Time:2022-05-05T10:24:18.8093649Z, Details: (none)

exit status 255

我错过了什么？

(我来自 AWS 背景，因此我很可能会根据这种经验来假设事情应该如何运作。)

Answer 1

显然，与 blob 交互无法使用 azidentity.NewDefaultAzureCredential() 提供的凭据。 Azure 需要 SAS token 或共享 key 才能使用 blob。下面是一个示例函数，可用于获取特定 blob 的客户端:

func getBlobClient(account, container, object string) (*azblob.BlockBlobClient, error) {
    accountKey, ok := os.LookupEnv("AZURE_STORAGE_ACCOUNT_KEY")
    if !ok {
        return nil, errors.New("AZURE_STORAGE_ACCOUNT_KEY could not be found")
    }

    credential, err := azblob.NewSharedKeyCredential(account, accountKey)
    if err != nil {
        return nil, err
    }

    accountPath := fmt.Sprintf("https://%s.blob.core.windows.net/", account)
    serviceClient, err := azblob.NewServiceClientWithSharedKey(accountPath, credential, nil)
    if err != nil {
        return nil, err
    }

    containerClient, err := serviceClient.NewContainerClient(container)
    if err != nil {
        return nil, err
    }

    blobClient, err := containerClient.NewBlockBlobClient(object)
    if err != nil {
        return nil, err
    }

    return blobClient, nil
}

这使用 AZURE_STORAGE_ACCOUNT_KEY 环境变量作为凭据。

可以找到的示例相当困惑(并且可能是错误的)，这里提出了一个问题:

https://github.com/Azure-Samples/storage-blobs-go-quickstart/issues/7