בדף הזה מוסבר איך לכתוב פונקציות Cloud Run מבוססות-HTTP ומבוססות-אירועים באמצעות Functions Framework.
סקירה כללית של Functions Framework
כשכותבים קוד מקור של פונקציות, צריך להשתמש ב-Functions Framework, ספריית קוד פתוח לכתיבת פונקציות Cloud Run. בעזרת Functions Framework אפשר לכתוב פונקציות קלות משקל שפועלות ב-Cloud Run ובסביבות אחרות, כולל במכונת הפיתוח המקומית ובסביבות שמבוססות על Knative.
ה-Functions Framework מאפשר לכם:
- הפעלת פונקציית Cloud Run בתגובה לבקשה.
- האירועים שתואמים למפרט CloudEvents מבוטלים באופן אוטומטי. זהו מפרט בתקן התעשייה לתיאור נתוני אירועים בדרך משותפת.
- מפעילים שרת פיתוח מקומי לבדיקה.
Functions Framework מספק ממשק ליצירת שירותים מודולריים. כדי להשתמש ב-Functions Framework בקוד המקור, צריך לציין את הפרטים הבאים:
נקודת כניסה לפונקציה
בקוד המקור צריך להגדיר נקודת כניסה לפונקציה, כלומר הקוד שמופעל כש-Cloud Run מפעיל את הפונקציה. מציינים את נקודת הכניסה הזו כשפורסים את הפונקציה.
הדרך להגדיר את נקודת הכניסה תלויה בסביבת זמן הריצה של השפה שבה אתם משתמשים. בשפות מסוימות משתמשים בפונקציה כנקודת הכניסה, ובשפות אחרות משתמשים במחלקה.
סוג החתימה
כשכותבים את קוד המקור של פונקציה באמצעות Functions Framework, צריך לציין אחד משני סוגי החתימות:
- פונקציות HTTP: רישום של פונקציית handler של HTTP. משתמשים בפונקציית HTTP כשהפונקציה צריכה נקודת קצה של כתובת URL וחייבת להגיב לבקשות HTTP, למשל עבור webhook.
- פונקציות מבוססות-אירועים, שנקראות גם פונקציות CloudEvents: רושמת פונקציית handler של CloudEvents. משתמשים בפונקציה מבוססת-אירועים כשהפונקציה מופעלת ישירות בתגובה לאירועים ב Google Cloud פרויקט, כמו הודעות בנושא Pub/Sub או שינויים בקטגוריה של Cloud Storage.
המבנה של ספריית קובצי המקור
ה-Functions Framework נתמך במספר שפות תכנות. השפה של זמן הריצה שבוחרים וסוג הפונקציה שרוצים לכתוב קובעים את המבנה של הקוד ואת אופן ההטמעה של הפונקציה.
כדי ש-Cloud Run יאתר את הגדרת הפונקציה, לכל סביבת זמן ריצה של שפה יש דרישות לגבי המבנה של קוד המקור.
Node.js
מבנה הספרייה הבסיסי של פונקציות Node.js הוא כדלקמן:
. ├── index.js └── package.json
כברירת מחדל, Cloud Run מנסה לטעון קוד מקור מקובץ בשם index.js בספריית הבסיס של הפונקציה. כדי לציין קובץ מקור ראשי אחר, משתמשים בשדה main בקובץ package.json.
קובץ package.json צריך לכלול גם את Functions Framework for Node.js כתלות:
{
"main": "index.js",
"dependencies": {
"@google-cloud/functions-framework": "^3.0.0"
},
"type": "module"
}
הקוד בקובץ הראשי צריך להגדיר את נקודת הכניסה של הפונקציה, ויכול לייבא קוד אחר ומודולים של Node.js. בנוסף, בקובץ הראשי אפשר להגדיר כמה נקודות כניסה לפונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמרים סקירה כללית של סביבת זמן הריצה של Node.js וFunctions Framework for Node.js.
Python
מבנה הספריות הבסיסי של פונקציות Python הוא כדלקמן:
. ├── main.py └── requirements.txt
Cloud Run טוען קוד מקור מקובץ בשם main.py שנמצא בספרייה הבסיסית של הפונקציה. צריך לתת לקובץ הראשי את השם main.py.
קובץ requirements.txt צריך לכלול את Functions Framework for Python כתלות:
functions-framework==3.*
הקוד בקובץ main.py צריך להגדיר את נקודת הכניסה של הפונקציה, ויכול לייבא קוד אחר ותלות חיצונית כרגיל. קובץ main.py יכול להגדיר גם כמה נקודות כניסה לפונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמר סקירה כללית של זמן הריצה של Python ובמאמר Functions Framework for Python.
המשך
המבנה הבסיסי של ספרייה לפונקציות Go הוא כדלקמן:
. ├── myfunction.go └── go.mod
הפונקציה צריכה להיות בחבילת Go בשורש הפרויקט. לחבילה ולקובצי המקור שלה יכול להיות כל שם, אבל הפונקציה לא יכולה להיות ב-package main. אם אתם צריכים חבילה של main, למשל לבדיקות מקומיות, אתם יכולים ליצור אותה בספריית משנה:
. ├── myfunction.go ├── go.mod └── cmd/ └── main.go
קובץ ה-go.mod צריך לכלול את Functions Framework for Go כתלות:
module example.com/my-module
require (
github.com/GoogleCloudPlatform/functions-framework-go v1.5.2
)
הקוד בחבילת הבסיס צריך להגדיר את נקודת הכניסה של הפונקציה, ויכול לייבא קוד אחר מחבילות משנה ומקובצי תלות כרגיל. החבילה יכולה גם להגדיר כמה נקודות כניסה לפונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמרים בנושא סקירה כללית של זמן הריצה של Go וFunctions Framework for Go.
Java
מבנה הספריות הבסיסי של פונקציות Java הוא כדלקמן:
.
├── pom.xml
└── src/
└── main/
└── java/
└── MyFunction.java
קבצי המקור של Java צריכים להיות בתיקייה src/main/java/, והשם שלהם יכול להיות כל שם. אם קובצי המקור מגדירים חבילה, מוסיפים עוד תיקייה מתחת ל-src/main/java עם שם החבילה:
.
├── pom.xml
└── src/
└── main/
└── java/
└── mypackage/
└── MyFunction.java
מומלץ למקם את הבדיקות המשויכות בספריית משנה src/test/java/.
קובץ ה-pom.xml צריך לכלול את Functions Framework for Java כתלות:
...
<dependency>
<groupId>com.google.cloud.functions</groupId>
<artifactId>functions-framework-api</artifactId>
<version>1.0.4</version>
</dependency>
...
הקוד בקובצי המקור צריך להגדיר את נקודת הכניסה של הפונקציה, ואפשר לייבא קוד אחר ותלות חיצונית כרגיל. בקבצי המקור אפשר גם להגדיר כמה נקודות כניסה של פונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמרים בנושא סקירה כללית של Java runtime ו-Functions Framework for Java.
.NET
מבנה הספריות הבסיסי של פונקציות .NET הוא כדלקמן:
. ├── MyFunction.cs └── MyProject.csproj
אתם יכולים לבנות את הפרויקטים כמו כל קוד מקור אחר של .NET. קובצי המקור יכולים להיות בכל שם.
קובץ הפרויקט צריך לכלול את Functions Framework for .NET כתלות:
...
<PackageReference Include="Google.Cloud.Functions.Hosting" Version="1.0.0" />
...
הקוד בקובצי המקור צריך להגדיר את נקודת הכניסה של הפונקציה, ואפשר לייבא קוד אחר ותלות חיצונית כרגיל. בקבצי המקור אפשר גם להגדיר כמה נקודות כניסה של פונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמר סקירה כללית של זמן הריצה של .NET ובמאמר Functions Framework for .NET.
Ruby
מבנה הספריות הבסיסי של פונקציות Ruby הוא כדלקמן:
. ├── app.rb ├── Gemfile └── Gemfile.lock
Cloud Run טוען קוד מקור מקובץ בשם app.rb שנמצא בספרייה הבסיסית של הפונקציה. הקובץ הראשי צריך להיקרא app.rb.
קובץ ה-Gemfile צריך לכלול את Functions Framework for Ruby כתלות:
source "https://rubygems.org"
gem "functions_framework", "~> 1.0"
הקוד בקובץ app.rb צריך להגדיר את נקודת הכניסה של הפונקציה, ויכול לייבא קוד אחר ותלות חיצונית כרגיל. קובץ app.rb יכול להגדיר גם כמה נקודות כניסה לפונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמר סקירה כללית של זמן הריצה של Ruby ובמאמר בנושא Functions Framework for Ruby.
PHP
מבנה הספריות הבסיסי של פונקציות PHP הוא כדלקמן:
. ├── index.php └── composer.json
Cloud Run טוען קוד מקור מקובץ בשם index.php שנמצא בספרייה הבסיסית של הפונקציה. צריך לתת לקובץ הראשי את השם index.php.
קובץ composer.json צריך לכלול את Functions Framework for PHP כתלות:
{
"require": {
"google/cloud-functions-framework": "^1.1"
}
}
הקוד בקובץ index.php צריך להגדיר את נקודת הכניסה של הפונקציה, ויכול לייבא קוד אחר ותלות חיצונית כרגיל. קובץ index.php יכול להגדיר גם כמה נקודות כניסה לפונקציות שאפשר לפרוס בנפרד.
פרטים נוספים זמינים במאמר סקירה כללית של זמן הריצה של PHP ובמאמר בנושא Functions Framework for PHP.
אם מקבצים כמה פונקציות לפרויקט אחד, צריך לזכור שכל הפונקציות עשויות לחלוק את אותה קבוצה של תלות. עם זאת, יכול להיות שחלק מהפונקציות לא יזדקקו לכל התלויות.
במקרים שבהם הדבר אפשרי, מומלץ לפצל בסיסי קוד גדולים עם כמה פונקציות, ולהציב כל פונקציה בספרייה משלה ברמה העליונה, כמו בדוגמאות הקודמות, עם קובץ מקור וקובץ הגדרות פרויקט משלה. הגישה הזו מצמצמת את מספר התלויות שנדרשות לפונקציה מסוימת, וכך מקטינה את כמות הזיכרון שהפונקציה צריכה.
כתיבת פונקציות HTTP
כותבים פונקציית HTTP כשרוצים להפעיל פונקציה באמצעות בקשת HTTP(S). כדי לאפשר סמנטיקה של HTTP, משתמשים ב-Function Framework ומציינים את חתימת הפונקציה של HTTP כדי לקבל ארגומנטים ספציפיים ל-HTTP.
בדוגמה הבאה מוצג קובץ מקור של פונקציית HTTP בסיסית לכל סביבת זמן ריצה. דוגמה מלאה ופעילה מופיעה במאמר פריסת פונקציה של Cloud Run באמצעות Google Cloud CLI. מידע נוסף על המיקום של קוד המקור זמין במאמר בנושא מבנה ספריית קובצי המקור.
Node.js
מודול ES
import { http } from '@google-cloud/functions-framework'; // Register an HTTP function with the Functions Framework that executes // when you make an HTTP request to the deployed function's endpoint. http('helloGET', (req, res) => { res.send('Hello World!'); });
מוסיפים את יחסי התלות הבאים לקובץ package.json:
{ "name": "nodejs-docs-samples-functions-hello-world-get", "version": "0.0.1", "private": true, "license": "Apache-2.0", "author": "Google Inc.", "repository": { "type": "git", "url": "https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git" }, "engines": { "node": ">=16.0.0" }, "scripts": { "test": "c8 mocha -p -j 2 test/*.test.js --timeout=6000 --exit" }, "dependencies": { "@google-cloud/functions-framework": "^3.1.0" }, "devDependencies": { "c8": "^10.0.0", "gaxios": "^6.0.0", "mocha": "^10.0.0", "wait-port": "^1.0.4" } }
מודול CommonJS
const functions = require('@google-cloud/functions-framework');
// Register an HTTP function with the Functions Framework
functions.http('helloGET', (req, res) => {
// Your code here
// Send an HTTP response
res.send('OK');
});
מוסיפים את יחסי התלות הבאים לקובץ package.json:
{
"dependencies": {
"@google-cloud/functions-framework": "^3.0.0"
}
}
ב-Node.js, רושמים פונקציית handler של HTTP באמצעות Functions Framework ל-Node.js. פונקציית ה-handler של HTTP חייבת להיות פונקציית תווכה של Express שמקבלת את הארגומנטים request ו-response ושולחת תגובת HTTP.
Cloud Run מנתח באופן אוטומטי את גוף הבקשה על סמך הכותרת Content-Type של הבקשה באמצעות body-parser, כך שאתם יכולים לגשת לאובייקטים req.body ו-req.rawBody ב-HTTP handler.
נקודת הכניסה של הפונקציה היא השם שבו רשום ה-handler ב-Functions Framework.
בדוגמה הזו, נקודת הכניסה היא helloGET.
Python
import functions_framework
# Register an HTTP function with the Functions Framework
@functions_framework.http
def my_http_function(request):
# Your code here
# Return an HTTP response
return 'OK'
ב-Python, רושמים פונקציית handler של HTTP באמצעות Functions Framework for Python. פונקציית הטיפול ב-HTTP צריכה לקבל אובייקט Flask request כארגומנט ולהחזיר ערך ש-Flask יכול להמיר לאובייקט תגובת HTTP.
נקודת הכניסה של הפונקציה היא השם שבו רשום ה-handler ב-Functions Framework.
בדוגמה הזו, נקודת הכניסה היא my_http_function.
המשך
package myhttpfunction
import (
"fmt"
"net/http"
"github.com/GoogleCloudPlatform/functions-framework-go/functions"
)
func init() {
// Register an HTTP function with the Functions Framework
functions.HTTP("MyHTTPFunction", myHTTPFunction)
}
// Function myHTTPFunction is an HTTP handler
func myHTTPFunction(w http.ResponseWriter, r *http.Request) {
// Your code here
// Send an HTTP response
fmt.Fprintln(w, "OK")
}
ב-Go, רושמים פונקציה לטיפול ב-HTTP באמצעות Functions Framework for Go בפונקציה init(). פונקציית ה-handler של HTTP צריכה להשתמש בממשק http.HandlerFunc הרגיל כדי לשלוח תגובת HTTP.
נקודת הכניסה של הפונקציה היא השם שבו רשום ה-handler ב-Functions Framework.
בדוגמה הזו, נקודת הכניסה היא MyHTTPFunction.
פונקציית ה-handler של HTTP חייבת להטמיע את הממשק הרגיל http.HandlerFunc. היא מקבלת ממשק http.ResponseWriter שהפונקציה שלכם משתמשת בו כדי ליצור תשובה לבקשה, ומצביע למבנה http.Request שמכיל את הפרטים של בקשת ה-HTTP הנכנסת.
Java
package myhttpfunction;
import com.google.cloud.functions.HttpFunction;
import com.google.cloud.functions.HttpRequest;
import com.google.cloud.functions.HttpResponse;
// Define a class that implements the HttpFunction interface
public class MyHttpFunction implements HttpFunction {
// Implement the service() method to handle HTTP requests
@Override
public void service(HttpRequest request, HttpResponse response) throws Exception {
// Your code here
// Send an HTTP response
response.getWriter().write("OK");
}
}
ב-Java, משתמשים ב-Functions Framework Java API כדי להטמיע מחלקה של handler ל-HTTP עם הממשק HttpFunction. השיטה service() חייבת לשלוח תגובת HTTP.
נקודת הכניסה של הפונקציה היא השם המלא של מחלקת ה-handler של ה-HTTP, כולל שם החבילה. בדוגמה הזו, נקודת הכניסה היא myhttpfunction.MyHttpFunction.
השיטה service מקבלת אובייקט HttpRequest שמתאר את בקשת ה-HTTP הנכנסת, ואובייקט HttpResponse שהפונקציה מאכלסת בהודעת תגובה.
.NET
using Google.Cloud.Functions.Framework;
using Microsoft.AspNetCore.Http;
using System.Threading.Tasks;
namespace MyProject
{
// Define a class that implements the IHttpFunction interface
public class MyHttpFunction : IHttpFunction
{
// Implement the HandleAsync() method to handle HTTP requests
public async Task HandleAsync(HttpContext context)
{
// Your code here
// Send an HTTP response
await context.Response.WriteAsync("OK");
}
}
}
בזמני ריצה של .NET, משתמשים ב-Functions Framework for .NET כדי להטמיע מחלקה של handler ל-HTTP עם הממשק IHttpFunction. השיטה HandleAsync() מקבלת אובייקט HttpContext סטנדרטי של ASP.NET כארגומנט, והיא חייבת לשלוח תגובת HTTP.
נקודת הכניסה של הפונקציה היא השם המלא של מחלקת ה-handler של HTTP, כולל מרחב השמות. בדוגמה הזו, נקודת הכניסה היא MyProject.MyHttpFunction.
Ruby
require "functions_framework"
# Register an HTTP function with the Functions Framework
FunctionsFramework.http "my_http_function" do |request|
# Your code here
# Return an HTTP response
"OK"
end
ב-Ruby, רושמים פונקציה לטיפול ב-HTTP באמצעות Functions Framework for Ruby. פונקציית ה-handler של HTTP חייבת לקבל אובייקט Rack request כארגומנט ולהחזיר ערך שאפשר להשתמש בו כתגובת HTTP.
נקודת הכניסה של הפונקציה היא השם שבו רשום ה-handler ב-Functions Framework.
בדוגמה הזו, נקודת הכניסה היא my_http_function.
PHP
<?php
use Google\CloudFunctions\FunctionsFramework;
use Psr\Http\Message\ServerRequestInterface;
// Register an HTTP function with the Functions Framework
FunctionsFramework::http('myHttpFunction', 'myHttpHandler');
// Define your HTTP handler
function myHttpHandler(ServerRequestInterface $request): string
{
// Your code here
// Return an HTTP response
return 'OK';
}
ב-PHP, רושמים פונקציית handler של HTTP באמצעות Functions Framework for PHP.
פונקציית הטיפול ב-HTTP חייבת לקבל ארגומנט שמיישם את הממשק PSR-7
ServerRequestInterface
ולחזיר תגובת HTTP כמחרוזת או כאובייקט שמיישם את הממשק PSR-7
ResponseInterface.
נקודת הכניסה של הפונקציה היא השם שבו רשום ה-handler ב-Functions Framework.
בדוגמה הזו, נקודת הכניסה היא myHttpFunction.
בקשות ותגובות HTTP
כשרושמים פונקציית handler של HTTP ב-Functions Framework, פונקציית ה-handler של HTTP יכולה לבדוק את שיטת הבקשה ולבצע פעולות שונות על סמך השיטה.
כשמגדירים ספק אירועים לשליחת בקשות HTTP לפונקציית Cloud Run, הפונקציה שולחת תגובת HTTP. אם הפונקציה יוצרת משימות ברקע (כמו עם threads, futures, JavaScript Promise objects, callbacks או תהליכי מערכת), צריך לסיים את המשימות האלה או לפתור אותן בדרך אחרת לפני ששולחים תגובת HTTP. יכול להיות שמשימות שלא הסתיימו לפני שליחת תגובת ה-HTTP לא יושלמו, ועלולות לגרום להתנהגות לא מוגדרת.
טיפול ב-CORS
שיתוף משאבים בין מקורות (CORS) הוא דרך לאפשר לאפליקציות שפועלות בדומיין אחד לגשת למשאבים מדומיין אחר. לדוגמה, יכול להיות שתצטרכו לאפשר לדומיין שלכם לשלוח בקשות לדומיין של פונקציות Cloud Run כדי לגשת לפונקציה.
כדי לאפשר לבקשות ממקורות שונים לגשת לפונקציה, צריך להגדיר את הכותרת Access-Control-Allow-Origin בתגובת ה-HTTP. במקרה של בקשות קדם-הפעלה ממקורות שונים, צריך להשיב לבקשת קדם-ההפעלה OPTIONS עם קוד תגובה 204 וכותרות נוספות.