如何将 ZIP 文件从 API 管理上传到 Blob 存储


  1. 我正在我的一个 Azure API 管理 API 上发送 POST 请求
  2. 在此 post 请求中,有一个包含 base64 编码数据(zip 文件(的 json 正文,如以下示例所示:

    { "foo": "bar", "data": "your-base64-string"}

  3. 在 API 策略中,我想向 Azure 存储 REST API 发送单独的请求,以将上述 base64 字符串保存为 zip 文件。

现在的问题是:我可以成功地将请求发送到 Azure 存储 REST API,并通过以下语句下载生成的 zip 文件:

<set-body>@{
var base64String = (string)context.Variables.GetValueOrDefault<JObject>("body")["data"]) ;
var bytes = Convert.FromBase64String(base64String); 
var ascii = Encoding.ASCII.GetString(bytes); 
return ascii; 
}</set-body> 

问题是,我可以下载并打开zip文件,但由于存档已损坏,因此无法提取其内容。

下面是一个示例 base64 编码的 zip 文件字符串(包含文本的 ZIP 文件.txt(:

UEsDBBQAAAAIAL1ZxE7MTbG/EwAAABMAAAAIAAAAdGVzdC50eHQLycgsVgCiRIWS1OKStMycVD0AUEsBAh8AFAAAAAgAvVnETsxNsb8TAAAAEwAAAAgAJAAAAAAAAAAgAAAAAAAAAHRlc3QudHh0CgAgAAAAAAABABgAI8Ac2LUa1QEjwBzYtRrVAZFuI861GtUBUEsFBgAAAAABAAEAWgAAADkAAAAAAA==

这是我将其发布到 Rest API 的代码:

<send-request mode="new" response-variable-name="putStorageRequest" timeout="5" ignore-error="true">
            <set-url>@((string)context.Variables["blobUrl"])</set-url>
            <set-method>PUT</set-method>
            <set-header name="x-ms-date" exists-action="override">
                <value>@((string) context.Variables["date"] )</value>
            </set-header>
            <set-header name="x-ms-version" exists-action="override">
                <value>@((string) context.Variables["version"] )</value>
            </set-header>
            <set-header name="x-ms-blob-type" exists-action="override">
                <value>BlockBlob</value>
            </set-header>
            <set-header name="Content-Type" exists-action="override">
                <value>application/zip</value>
            </set-header>
            <set-header name="Authorization" exists-action="override">
                <value>@{
                        string body = context.Request.Body.As<string>(preserveContent: true);
                        string contentType = "application/zip";
                        var base64String = (string)context.Variables.GetValueOrDefault<JObject>("body")["data"]) ;
            var bytes = Convert.FromBase64String(base64String); 
            var ascii = Encoding.ASCII.GetString(bytes)
                        var contentLength = ascii.Length;
                        var hmacSha256 = new System.Security.Cryptography.HMACSHA256 { Key = Convert.FromBase64String(context.Variables.GetValueOrDefault<string>("storageKey")) };
                        var payLoad = string.Format("{0}nnn{1}nn{2}nnnnnnnx-ms-blob-type:BlockBlobnx-ms-date:{3}nx-ms-version:{4}n{5}", 
                            "PUT", 
                            contentLength,
                            contentType,
                            context.Variables["date"],
                            context.Variables["version"],
                            "/" + context.Variables.GetValueOrDefault<string>("storageAccountName") + context.Variables.GetValueOrDefault<string>("resource"));
                        return "SharedKey "+ context.Variables.GetValueOrDefault<string>("storageAccountName") + ":" + Convert.ToBase64String(hmacSha256.ComputeHash(Encoding.UTF8.GetBytes(payLoad)));
                    }</value>
            </set-header>
            <set-body>@{
                var base64String = (string)context.Variables.GetValueOrDefault<JObject>("body")["data"]) ;
                var bytes = Convert.FromBase64String(base64String); 
                var ascii = Encoding.ASCII.GetString(bytes); 
                return ascii;         
            }</set-body>
        </send-request>

Azure API Management 现在在正文中支持 byte[]:

https://azure.microsoft.com/en-us/updates/azure-api-management-update-september-2019

设置正文策略还接受字节数组作为正文内容。

通过在 Blob 存储中创建一个 zip 文件,我的测试成功了,下载了它,打开了 zip 文件并打开了包含的文本文件。

使用了以下代码:

            <set-header name="Authorization" exists-action="override">
            <value>@{
                    string body = context.Request.Body.As<string>(preserveContent: true);
                    string contentType = "application/zip";
                    var base64String = (string)context.Variables.GetValueOrDefault<JObject>("body")["data"] ;
                    var bytes = Convert.FromBase64String(base64String); 
                    var contentLength = bytes.Length;
                    var hmacSha256 = new System.Security.Cryptography.HMACSHA256 { Key = Convert.FromBase64String(context.Variables.GetValueOrDefault<string>("storageKey")) };
                    var payLoad = string.Format("{0}nnn{1}nn{2}nnnnnnnx-ms-blob-type:BlockBlobnx-ms-date:{3}nx-ms-version:{4}n{5}", 
                        "PUT", 
                        contentLength,
                        contentType,
                        context.Variables["date"],
                        context.Variables["version"],
                        "/" + context.Variables.GetValueOrDefault<string>("storageAccountName") + context.Variables.GetValueOrDefault<string>("resource"));
                    return "SharedKey "+ context.Variables.GetValueOrDefault<string>("storageAccountName") + ":" + Convert.ToBase64String(hmacSha256.ComputeHash(Encoding.UTF8.GetBytes(payLoad)));
                }</value>
        </set-header>
        <set-body>@{
            var base64String = (string)context.Variables.GetValueOrDefault<JObject>("body")["data"] ;
            var bytes = Convert.FromBase64String(base64String); 
            return bytes;         
        }</set-body>

我只需要删除:

var ascii = Encoding.ASCII.GetString(bytes); 

最新更新