在 Cloud Run 中建構及建立 Node.js 工作

編寫範例工作

如要在 Node.js 中編寫工作，請按照下列步驟操作：

1. 建立名為 jobs 的新目錄，然後將目錄變更為該目錄：

   mkdir jobs
   cd jobs
   

2. 使用以下內容建立 package.json 檔案：

   {
       "name": "jobs",
       "version": "1.0.0",
       "description": "Node.js sample for Cloud Run jobs",
       "main": "index.js",
       "scripts": {
           "start": "node index.js"
       },
       "engines": {
           "node": ">=16.0.0"
       },
       "author": "Google LLC",
       "license": "Apache-2.0"
   }
   

3. 在同一個目錄中，為實際工作代碼建立 index.js 檔案。將下列範例行複製到其中：

   // Retrieve Job-defined env vars
   const {CLOUD_RUN_TASK_INDEX = 0, CLOUD_RUN_TASK_ATTEMPT = 0} = process.env;
   // Retrieve User-defined env vars
   const {SLEEP_MS, FAIL_RATE} = process.env;
   
   // Define main script
   const main = async () => {
     console.log(
       `Starting Task #${CLOUD_RUN_TASK_INDEX}, Attempt #${CLOUD_RUN_TASK_ATTEMPT}...`
     );
     // Simulate work
     if (SLEEP_MS) {
       await sleep(SLEEP_MS);
     }
     // Simulate errors
     if (FAIL_RATE) {
       try {
         randomFailure(FAIL_RATE);
       } catch (err) {
         err.message = `Task #${CLOUD_RUN_TASK_INDEX}, Attempt #${CLOUD_RUN_TASK_ATTEMPT} failed.\n\n${err.message}`;
         throw err;
       }
     }
     console.log(`Completed Task #${CLOUD_RUN_TASK_INDEX}.`);
   };
   
   // Wait for a specific amount of time
   const sleep = ms => {
     return new Promise(resolve => setTimeout(resolve, ms));
   };
   
   // Throw an error based on fail rate
   const randomFailure = rate => {
     rate = parseFloat(rate);
     if (!rate || rate < 0 || rate > 1) {
       console.warn(
         `Invalid FAIL_RATE env var value: ${rate}. Must be a float between 0 and 1 inclusive.`
       );
       return;
     }
   
     const randomFailure = Math.random();
     if (randomFailure < rate) {
       throw new Error('Task failed.');
     }
   };
   
   // Start script
   main().catch(err => {
     console.error(err);
     process.exit(1); // Retry Job Task by exiting the process
   });

   Cloud Run 工作可讓使用者指定工作要執行的工作數量。以下程式碼範例說明如何使用內建的 CLOUD_RUN_TASK_INDEX 環境變數。每個工作都代表一個正在執行的容器副本。請注意，工作通常會並行執行。如果每個工作都能獨立處理部分資料，使用多個工作就很實用。

   每項工作都會知道自己的索引，並儲存在 CLOUD_RUN_TASK_INDEX 環境變數中。內建的 CLOUD_RUN_TASK_COUNT 環境變數包含透過 --tasks 參數在工作執行期間提供的工作數量。

   顯示的程式碼也說明如何使用內建的 CLOUD_RUN_TASK_ATTEMPT 環境變數重試工作，其中包含重試此工作的次數，從第一次嘗試開始，每次重試增加 1，最多可達 --max-retries。

   您也可以透過這段程式碼產生失敗情況，以便測試重試，並產生錯誤記錄，讓您瞭解這些記錄的樣貌。

4. 使用以下內容建立 Procfile：

   # Define the application's entrypoint to override default, `npm start`
   # https://github.com/GoogleCloudPlatform/buildpacks/issues/160
   web: node index.js
   

程式碼已完成，可以封裝在容器中。

建構工作容器、將其傳送至 Artifact Registry，然後部署至 Cloud Run

重要事項：本快速入門假設您在用於快速入門的專案中具備擁有者或編輯者角色。否則，請參閱 Cloud Run 原始碼開發人員角色，瞭解從原始碼部署 Cloud Run 資源所需的權限。

本快速入門導覽課程會使用「從來源部署」功能，該功能會建構容器、上傳至 Artifact Registry，並將工作部署至 Cloud Run：

gcloud run jobs deploy job-quickstart \
    --source . \
    --tasks 50 \
    --set-env-vars SLEEP_MS=10000 \
    --set-env-vars FAIL_RATE=0.1 \
    --max-retries 5 \
    --region REGION \
    --project=PROJECT_ID

其中 PROJECT_ID 是您的專案 ID，REGION 則是您的區域，例如 us-central1。請注意，您可以將各種參數變更為要用於測試的任何值。SLEEP_MS 會模擬工作，而 FAIL_RATE 會導致 X% 的工作失敗，讓您嘗試並行處理和重試失敗的工作。

在 Cloud Run 中執行工作

如要執行剛建立的工作，請按照下列步驟操作：

gcloud run jobs execute job-quickstart --region REGION

將 REGION 替換為您在建立及部署工作時使用的地區，例如 us-central1。