全部產品
Search
文件中心

Function Compute:函數執行個體生命週期回調方法

更新時間:Jul 06, 2024

本文介紹Java運行時實現函數執行個體生命週期回調的方法。

背景資訊

當您實現並配置函數執行個體生命週期回調後,Function Compute系統將在相關執行個體生命週期事件發生時調用對應的回調程式。當前PHP運行時支援Initializer和PreStop兩種函數執行個體生命週期回呼函數。更多資訊,請參見配置執行個體生命週期

函數執行個體生命週期回調程式與正常調用請求計費規則一致,但其執行日誌只能在函數日誌即時日誌進階日誌中查詢,調用請求列表不會展示回調程式日誌。具體操作,請參見查看執行個體生命週期回呼函數日誌

回調方法簽名

Initializer回調簽名

初始化回調程式(Initializer回調)是在函數執行個體啟動成功之後,運行請求處理常式(Handler)之前執行。Function Compute保證在一個執行個體生命週期內,成功且只成功執行一次Initializer回調。例如您的Initializer回調第一次執行失敗了,系統會重試,直到成功為止,然後再執行您的請求處理常式。因此,您在實現Initializer回調時,需要保證它被重複調用時的正確性。

Initializer回調只有一個context輸入參數,使用方法同事件請求處理常式。

使用Initializer回調需要繼承FunctionInitializer介面,並實現該介面的initialize方法,介面定義如下。

package com.aliyun.fc.runtime;

import java.io.IOException;

/**
 * This is the interface for the initialization operation
 */
public interface FunctionInitializer {

    /**
     * The interface to handle a function compute initialize request
     *
     * @param context The function compute initialize environment context object.
     * @throws IOException IOException during I/O handling
     */
    void initialize(Context context) throws IOException;
}

PreStop回調簽名

預停止回調程式(PreStop回調)在函數執行個體銷毀前執行,使用PreStop回調需要繼承PreStopHandler介面,並實現該介面的preStop方法,介面定義如下。

package com.aliyun.fc.runtime;

import java.io.IOException;

/**
 * This is the interface for the preStop operation
 */
public interface PreStopHandler {

    /**
     * The interface to handle a function compute preStop request
     *
     * @param context The function compute preStop environment context object.
     * @throws IOException IOException during I/O handling
     */
    void preStop(Context context) throws IOException;
}

簡單樣本:流式事件請求處理常式

package example;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import com.aliyun.fc.runtime.Context;
import com.aliyun.fc.runtime.StreamRequestHandler;
import com.aliyun.fc.runtime.FunctionInitializer;
import com.aliyun.fc.runtime.PreStopHandler;

public class App implements StreamRequestHandler, FunctionInitializer, PreStopHandler {
    @Override
    public void initialize(Context context) throws IOException {
        context.getLogger().info("initialize start ...");
    }

    @Override
    public void handleRequest(
            InputStream inputStream, OutputStream outputStream, Context context) throws IOException {
        context.getLogger().info("handlerRequest ...");
        outputStream.write(new String("hello world\n").getBytes());
    }

    @Override
    public void preStop(Context context) throws IOException {
        context.getLogger().info("preStop start ...");
    }
}

配置生命週期回呼函數

通過控制台配置

Function Compute控制台FC函數配置中設定生命週期回調,回調格式為[包名].[類名]::[方法名]。樣本如下:db_java_lifecycle

  • Initializer回調程式:設定為example.App::initialize,表示實現example包中App.java檔案裡的initialize方法。

  • PreStop回調程式:設定為example.App::preStop,表示實現example包中App.java檔案裡的preStop方法。

通過Serverless Devs配置

如果使用Serverless Devs工具,需要在s.yaml設定檔中添加Initializer 回調程式PreFreeze 回調程式PreStop 回調程式

  • Initializer回調配置

    function配置下添加instanceLifecycleConfig.initializer欄位,包括handlertimeout兩個欄位。

  • PreStop回調配置

    function配置下添加instanceLifecycleConfig.preStop欄位,包括handlertimeout兩個欄位。

具體的樣本如下所示。

# ------------------------------------
#   官方手冊: https://manual.serverless-devs.com/user-guide/aliyun/#fc3
#   常見小貼士: https://manual.serverless-devs.com/user-guide/tips/
#   有問題快來DingTalk群問一下吧:33947367
# ------------------------------------
edition: 3.0.0
name: hello-world-app
access: "default"

vars: # 全域變數
  region: "cn-hangzhou"

resources:
  hello_world:
    component: fc3 
    actions:       
      pre-${regex('deploy|local')}: 
        - run: mvn package -DskipTests
          path: ./
    props:
      region: ${vars.region}              
      functionName: "start-java-1xqf"
      description: 'hello world by serverless devs'
      runtime: "java8"
      code: ./target/HelloFCJava-1.0-SNAPSHOT-jar-with-dependencies.jar
      handler: example.App::handleRequest
      memorySize: 128
      timeout: 10
      instanceLifecycleConfig:      # 擴充函數
        initializer:                # initializer函數
          handler: example.App::initialize
          timeout: 60     
        preStop:                    # PreStop函數
          handler: example.App::preStop  # 函數入口
          timeout: 60               # 逾時時間
 

關於Serverless Devs的YAML配置規範,請參見Serverless Devs常用命令

查看執行個體生命週期回呼函數日誌

您可以通過函數日誌功能查看回呼函數日誌。

  1. 登入Function Compute控制台,在左側導覽列,單擊函數

  2. 在頂部功能表列,選擇地區,然後在函數頁面,單擊目標函數。

  3. 在函數詳情頁面,選擇測試頁簽,單擊測試函數,然後選擇日誌 > 函數日誌

    函數日誌頁簽,您可以查看函數的調用日誌和Initializer回調日誌,樣本如下。

    2024-03-04 17:57:28FC Initialize Start RequestId: 1-65e59b07-1520da26-bf73bbb91b69
    2024-03-04 17:57:282024-03-04 09:57:28.192 1-65e59b07-1520da26-bf73bbb91b69 [info] initializer
    2024-03-04 17:57:28FC Initialize End RequestId: 1-65e59b07-1520da26-bf73bbb91b69
    2024-03-04 17:57:28FC Invoke Start RequestId: 1-65e59b07-1520da26-bf73bbb91b69
    2024-03-04 17:57:28FC Invoke End RequestId: 1-65e59b07-1520da26-bf73bbb91b69

    因為每個函數執行個體會緩衝一段時間,不會馬上銷毀,因此不能立即查看PreStop回調日誌。如需快速觸發PreStop回調,可更新函數配置或者函數代碼。更新完成後,再次查看函數日誌,您可以查看PreStop回調日誌。樣本如下。

    2024-03-04 18:33:26FC PreStop Start RequestId: 93c93603-9fbe-4576-9458-193c8b213031
    2024-03-04 18:33:262024-03-04 10:33:26.077 93c93603-9fbe-4576-9458-193c8b213031 [info] preStop
    2024-03-04 18:33:26FC PreStop End RequestId: 93c93603-9fbe-4576-9458-193c8b213031

樣本程式

  • java11-mysqlFunction Compute提供的Initializer回調和PreStop回調的樣本程式。

    該樣本為您展示了如何使用Java運行時的Initializer回調從環境變數中擷取資料庫配置並建立MySQL串連,以及如何使用PreStop回調負責關閉MySQL串連。