日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

編寫處理GetObject請求的函數

通過對象FC接入點訪問GetObject API時,將觸發您所綁定的函數計算服務中的函數,并在函數中配合WriteGetObjectResponse接口實現自定義返回數據和響應標頭。

前提條件

已創建對象FC接入點。具體操作,請參見創建對象FC接入點

操作步驟

  1. 編寫處理GetObject請求的函數示例。

    Java

    Java SDK要求3.17.2及以上版本。

    import com.aliyun.fc.runtime.Context;
    import com.aliyun.fc.runtime.Credentials;
    import com.aliyun.fc.runtime.StreamRequestHandler;
    import com.aliyun.oss.ClientException;
    import com.aliyun.oss.OSS;
    import com.aliyun.oss.OSSClientBuilder;
    import com.aliyun.oss.OSSException;
    import com.aliyun.oss.model.ObjectMetadata;
    import com.aliyun.oss.model.VoidResult;
    import com.aliyun.oss.model.WriteGetObjectResponseRequest;
    import org.codehaus.jettison.json.JSONException;
    import org.codehaus.jettison.json.JSONObject;
    import javax.imageio.ImageIO;
    import java.awt.*;
    import java.awt.image.BufferedImage;
    import java.io.*;
    import java.util.Scanner;
    
    public class Example1 implements StreamRequestHandler {
        // Endpoint以華北1(青島)為例。
        String endpoint = "https://oss-cn-qingdao.aliyuncs.com";
        private static int status = 200;
    
        public static String convertToString(InputStream inputStream) {
            Scanner scanner = new Scanner(inputStream).useDelimiter("\\A");
            return scanner.hasNext() ? scanner.next() : "";
        }
    
        @Override
        public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException {
            Credentials creds = context.getExecutionCredentials();
            // 從上下文中獲取訪問密鑰。
            OSS ossClient = new OSSClientBuilder().build(endpoint, creds.getAccessKeyId(), creds.getAccessKeySecret(), creds.getSecurityToken());
    
    
            try {
                String result = convertToString(inputStream);
                JSONObject jsonObject = new JSONObject(result);
                String route = jsonObject.getJSONObject("getObjectContext").getString("outputRoute");
                String token = jsonObject.getJSONObject("getObjectContext").getString("outputToken");
                // 通過調用BufferedImage創建200*200像素的對象,并為該對象繪制紅色的矩形框。
                // 完成以上調整后,將內容寫入WriteGetObjectResponse請求的主體中。
                BufferedImage image = new BufferedImage(200, 200, BufferedImage.TYPE_INT_RGB);
                Graphics2D graphics = image.createGraphics();
                graphics.setColor(Color.RED);
                graphics.fillRect(0, 0, 200, 200);
                graphics.dispose();
    
                ByteArrayOutputStream baos = new ByteArrayOutputStream();
                ImageIO.write(image, "png", baos);
                WriteGetObjectResponseRequest writeGetObjectResponseRequest = new WriteGetObjectResponseRequest(route, token, status,new ByteArrayInputStream(baos.toByteArray()));
    
                ObjectMetadata metadata = new ObjectMetadata();
                metadata.setContentLength(baos.size());
                writeGetObjectResponseRequest.setMetadata(metadata);
    
                VoidResult voidResult = ossClient.writeGetObjectResponse(writeGetObjectResponseRequest);
                System.out.println("getRequestId:"+voidResult.getRequestId());
                System.out.println("status:"+voidResult.getResponse().getStatusCode());
                System.out.println("Headers:"+voidResult.getResponse().getHeaders().toString());
            } catch (OSSException oe) {
                System.out.println("Caught an OSSException, which means your request made it to OSS, "
                        + "but was rejected with an error response for some reason.");
                System.out.println("Error Message: " + oe.getMessage());
                System.out.println("Error Code:       " + oe.getErrorCode());
                System.out.println("Request ID:      " + oe.getRequestId());
                System.out.println("Host ID:           " + oe.getHostId());
            } catch (ClientException ce) {
                System.out.println("Caught an ClientException, which means the client encountered "
                        + "a serious internal problem while trying to communicate with OSS, "
                        + "such as not being able to access the network.");
                System.out.println("Error Message: " + ce.getMessage());
            } catch (JSONException e) {
                e.printStackTrace();
            } finally {
                ossClient.shutdown();
            }
        }
    }
    

    Python

    Python SDK要求2.18.3及以上版本。

    # -*- coding: utf-8 -*-
    import io
    from PIL import Image
    import oss2
    import json
    
    # Endpoint以華北1(青島)為例。
    endpoint = 'http://oss-cn-qingdao.aliyuncs.com'
    fwd_status = '200'
    
    # Fc function entry
    def handler(event, context):
    
        evt = json.loads(event)
        creds = context.credentials
        # do not forget security_token
        auth = oss2.StsAuth(creds.access_key_id, creds.access_key_secret, creds.security_token)
    
        headers = dict()    
    
        event_ctx = evt["getObjectContext"]
        route = event_ctx["outputRoute"]
        token = event_ctx["outputToken"]
        print(evt)
    
        endpoint = route
        service = oss2.Service(auth, endpoint)
        # 通過調用Image方法創建200*200像素的對象,并為該對象繪制紅色的矩形框。
        # 完成以上調整后,將內容寫入write_get_object_response請求的主體中。
        image = Image.new('RGB', (200, 200), color=(255, 0, 0))
        transformed = io.BytesIO()
        image.save(transformed, "png")
    
        resp = service.write_get_object_response(route, token, fwd_status, transformed.getvalue(), headers)
    
        print('status: {0}'.format(resp.status))
        print(resp.headers)
    
        return 'success'

    Go

    Go SDK要求1.2.2及以上版本。

    package main
    
    import (
      "bytes"
      "context"
      "fmt"
      "github.com/aliyun/aliyun-oss-go-sdk/oss"
      "github.com/aliyun/fc-runtime-go-sdk/fc"
      "github.com/aliyun/fc-runtime-go-sdk/fccontext"
      "image"
      "image/color"
      "image/draw"
      "image/png"
    )
    // 定義GetObjectContext結構體,該結構體包含輸出路由(outputRoute)、輸出令牌(outputToken)和輸入OSS URL(inputOssUrl)。
    type GetObjectContext struct {
      OutputRoute string `json:"outputRoute"`
      OutputToken string `json:"outputToken"`
    }
    // 定義StructEvent結構體,用于接收觸發該函數的事件數據。
    type StructEvent struct {
      GetObjectContext GetObjectContext `json:"getObjectContext"`
    }
    // HandleRequest函數主要用于處理計算邏輯。
    func HandleRequest(ctx context.Context, event StructEvent) error {
      fmt.Printf("event:%#v\n", event)
      endpoint := event.GetObjectContext.OutputRoute
      fwdStatus := "200"
      fctx, _ := fccontext.FromContext(ctx)
      // 從上下文中獲取訪問密鑰。
      client, err := oss.New(endpoint, fctx.Credentials.AccessKeyId, fctx.Credentials.AccessKeySecret, oss.SecurityToken(fctx.Credentials.SecurityToken), oss.AuthVersion(oss.AuthV4), oss.Region("cn-qingdao"))
      if err != nil {
        return fmt.Errorf("client new error: %v", err)
      }
      params := map[string]interface{}{}
      params["x-oss-write-get-object-response"] = nil
    
      // 創建200*200像素的圖片,并繪制紅色的矩形框。
      img := image.NewRGBA(image.Rect(0, 0, 200, 200))
      red := color.RGBA{255, 0, 0, 255}
      draw.Draw(img, img.Bounds(), &image.Uniform{red}, image.Point{}, draw.Src)
    
      // 將圖片保存為PNG格式。
      var buf bytes.Buffer
      err = png.Encode(&buf, img)
      if err != nil {
        return fmt.Errorf("png encode error: %v", err)
      }
      reader := bytes.NewReader(buf.Bytes())
      // 通過OSS客戶端將轉換后的圖片以POST請求的形式上傳,并設置了特定的HTTP頭(例如x-oss-request-route),便于識別和處理特殊的轉發請求。
      headers := make(map[string]string)
      headers["x-oss-request-route"] = event.GetObjectContext.OutputRoute
      headers["x-oss-request-token"] = event.GetObjectContext.OutputToken
      headers["x-oss-fwd-status"] = fwdStatus
      resp, err := client.Conn.Do("POST", "", "", params, headers, reader, 0, nil)
      if err != nil {
        return fmt.Errorf("client conn do error: %v", err)
      }
      fmt.Println("status:", resp.StatusCode)
      fmt.Println(resp.Headers)
    
      return nil
    }
    // 啟動函數計算入口點,調用fc.Start(HandleRequest)來注冊并運行HandleRequest函數,等待并處理來自阿里云函數計算平臺的事件觸發。
    func main() {
      fc.Start(HandleRequest)
    }
  2. 部署函數。

    Java

    1. 自行打包.jar文件。

    2. 將.jar文件上傳至函數計算控制臺。

      1. 登錄函數計算控制臺,單擊右上角返回函數計算2.0

      2. 在左側導航欄,單擊服務及函數

      3. 在頂部導航欄,選擇華北1(青島)地域。

      4. 服務列表頁面,單擊已創建的服務,然后單擊已創建的運行環境為Java 11的函數。

      5. 在函數詳情頁面,選擇上傳代碼 > 上傳JAR

      6. 在彈出的對話框,選擇已打包的.jar文件,勾選我想在選中文件后直接部署函數,然后單擊保存并部署

    3. 根據函數示例對應修改請求處理程序(函數入口)。

      1. 在函數詳情頁面,單擊函數配置頁簽。

      2. 環境信息區域,單擊編輯

      3. 修改請求處理程序(函數入口)

        當運行環境為Java時,當前值的格式為[package].[class]::[method]。如果當前值為 example.HelloFC::handleRequest,則在函數被觸發時,將執行example包中HelloFC類下的handleRequest函數。您需要根據處理GetObject請求的函數示例的實際情況修改當前值,例如com.aliyun.sts.sample.Example1::handleRequest

    Python

    1. 服務列表頁面,單擊已創建的服務,然后單擊已創建的運行環境為Python 3.10的函數。

    2. 在函數詳情頁面,單擊函數代碼頁簽,然后選擇Terminal > New Terminal

    3. TERMINAL面板,輸入以下命令更新OSS Python SDK版本。

      pip install oss2 -t .
    4. index.py中的代碼示例替換為Python處理GetObject請求的函數示例,然后單擊部署函數

    Go

    1. 自行安裝Go SDK運行環境。

    2. 編譯代碼包。具體步驟,請參見編譯代碼包

      編譯過程中,根據需求將main.go編譯文件替換為上述步驟提供的需要處理GetObject請求的函數示例。

    3. 將編譯生成的二進制文件以ZIP包的形式上傳至已創建的運行環境Go 1的函數,并配置函數處理程序。具體步驟,請參見配置FC函數處理程序

后續步驟

使用對象FC接入點