הפעלת פונקציות מ-Pub/Sub באמצעות Eventarc

במדריך הזה נסביר איך לכתוב ולהפעיל פונקציות Cloud Run מבוססות-אירועים באמצעות טריגר של Pub/Sub.

אתם יכולים להגדיר את ניתוב האירועים, כולל מקור האירוע ויעד האירוע, על ידי ציון מסננים לטריגר של Eventarc. בדוגמה שבמדריך הזה, פרסום הודעה בנושא Pub/Sub מפעיל את האירוע, ובקשה נשלחת לפונקציה שלכם בצורה של בקשת HTTP.

אם אתם חדשים ב-Pub/Sub ורוצים לקבל מידע נוסף, עיינו במסמכי התיעוד של Pub/Sub כדי למצוא מדריכי Quickstart ומקורות מידע חשובים.

מטרות

במדריך הזה תלמדו:

  1. פריסת פונקציה מבוססת-אירועים.
  2. יוצרים טריגר של Eventarc.
  3. מפעילים את הפונקציה על ידי פרסום הודעה בנושא Pub/Sub.

עלויות

במסמך הזה משתמשים ברכיבים הבאים של Google Cloud, והשימוש בהם כרוך בתשלום:

בעזרת מחשבון העלויות אתם יכולים להעריך את העלויות בהתאם לשימוש הצפוי.

משתמשים חדשים של Google Cloud ? יכול להיות שאתם זכאים לתקופת ניסיון בחינם.

לפני שמתחילים

יכול להיות שאילוצי אבטחה שהוגדרו על ידי הארגון שלכם ימנעו מכם להשלים את השלבים הבאים. למידע על פתרון בעיות, קראו את המאמר פיתוח אפליקציות בסביבה מוגבלת של Google Cloud .

  1. נכנסים לחשבון Google Cloud . אנחנו ממליצים למשתמשים חדשים ב- Google Cloud ליצור חשבון כדי שיוכלו להעריך את הביצועים של המוצרים שלנו בתרחישים מהעולם האמיתי. לקוחות חדשים מקבלים בחינם גם קרדיט בשווי 300$ להרצה, לבדיקה ולפריסה של עומסי העבודה.
  2. התקינו את ה-CLI של Google Cloud.

  3. אם אתם משתמשים בספק זהויות חיצוני (IdP), קודם אתם צריכים להיכנס ל-CLI של gcloud באמצעות המאגר המאוחד לניהול זהויות.

  4. כדי לאתחל את ה-CLI של gcloud, הריצו את הפקודה הבאה:

    gcloud init
  5. יוצרים או בוחרים פרויקט ב- Google Cloud .

    התפקידים שנדרשים כדי לבחור או ליצור פרויקט

    • בחירת פרויקט: כדי לבחור פרויקט לא נדרש תפקיד IAM ספציפי – אתם יכולים לבחור כל פרויקט שקיבלתם בו תפקיד.
    • יצירת פרויקט: כדי ליצור פרויקט, צריך את התפקיד "יצירת פרויקטים" (roles/resourcemanager.projectCreator), שכולל את ההרשאה resourcemanager.projects.create. איך מקצים תפקידים?
    • יוצרים פרויקט ב- Google Cloud :

      gcloud projects create PROJECT_ID

      מחליפים את PROJECT_ID בשם של הפרויקט ב- Google Cloud שאתם יוצרים.

    • בוחרים את הפרויקט שיצרתם ב- Google Cloud :

      gcloud config set project PROJECT_ID

      מחליפים את PROJECT_ID בשם הפרויקט ב- Google Cloud .

  6. מוודאים שהחיוב מופעל בפרויקט ב- Google Cloud .

  7. התקינו את ה-CLI של Google Cloud.

  8. אם אתם משתמשים בספק זהויות חיצוני (IdP), קודם אתם צריכים להיכנס ל-CLI של gcloud באמצעות המאגר המאוחד לניהול זהויות.

  9. כדי לאתחל את ה-CLI של gcloud, הריצו את הפקודה הבאה:

    gcloud init
  10. יוצרים או בוחרים פרויקט ב- Google Cloud .

    התפקידים שנדרשים כדי לבחור או ליצור פרויקט

    • בחירת פרויקט: כדי לבחור פרויקט לא נדרש תפקיד IAM ספציפי – אתם יכולים לבחור כל פרויקט שקיבלתם בו תפקיד.
    • יצירת פרויקט: כדי ליצור פרויקט, צריך את התפקיד "יצירת פרויקטים" (roles/resourcemanager.projectCreator), שכולל את ההרשאה resourcemanager.projects.create. איך מקצים תפקידים?
    • יוצרים פרויקט ב- Google Cloud :

      gcloud projects create PROJECT_ID

      מחליפים את PROJECT_ID בשם של הפרויקט ב- Google Cloud שאתם יוצרים.

    • בוחרים את הפרויקט שיצרתם ב- Google Cloud :

      gcloud config set project PROJECT_ID

      מחליפים את PROJECT_ID בשם הפרויקט ב- Google Cloud .

  11. מוודאים שהחיוב מופעל בפרויקט ב- Google Cloud .

  12. אם אתם לא משתמשים ב-Cloud Shell, עדכנו את הרכיבים של Google Cloud CLI והתחברו באמצעות החשבון שלכם:
    gcloud components update
    gcloud auth login
  13. מפעילים את ממשקי ה-API:
    gcloud services enable artifactregistry.googleapis.com \
        cloudbuild.googleapis.com \
        eventarc.googleapis.com \
        run.googleapis.com \
        logging.googleapis.com \
        pubsub.googleapis.com
  14. מגדירים את משתני התצורה שמשמשים במדריך הזה:
    export REGION=us-central1
    gcloud config set run/region ${REGION}
    gcloud config set run/platform managed
    gcloud config set eventarc/location ${REGION}
  15. יוצרים חשבון שירות:
    SERVICE_ACCOUNT=eventarc-trigger-sa
    
    gcloud iam service-accounts create $SERVICE_ACCOUNT
  16. אם אתם כפופים לכלל מדיניות של הארגון של הגבלה לפי דומיין שמגבילה הפעלות לא מאומתות לפרויקט, תצטרכו לגשת לשירות שנפרס כמו שמתואר בקטע בדיקת שירותים פרטיים.

התפקידים הנדרשים

אתם או האדמין שלכם צריכים להקצות את תפקידי ה-IAM הבאים לחשבון הפריסה, לזהות של הטריגר, ולסוכני השירות של Pub/Sub ו-Cloud Storage (אופציונלי).

התפקידים הנדרשים לחשבון הפריסה

  1. אם אתם יוצרי הפרויקט, אתם מקבלים את התפקיד הבסיסי "בעלים" (roles/owner). כברירת מחדל, תפקיד ה-IAM הזה כולל את ההרשאות שנדרשות לגישה מלאה לרוב המשאבים של Google Cloud, ואתם יכולים לדלג על השלב הזה.

    אם אתם לא יוצרי הפרויקט, צריך לתת את ההרשאות הנדרשות בפרויקט לחשבון המשתמש המתאים. לדוגמה, חשבון משתמש יכול להיות חשבון Google (למשתמשי קצה) או חשבון שירות (לאפליקציות ולעומסי עבודה ממוחשבים). מידע נוסף זמין בדף תפקידים והרשאות של יעד האירוע.

    כדי לקבל את ההרשאות שדרושות להשלמת המדריך, בקשו מהאדמין להקצות לכם את התפקידים הבאים ב-IAM בפרויקט:

    להסבר על מתן תפקידים, ראו איך מנהלים את הגישה ברמת הפרויקט, התיקייה והארגון.

    יכול להיות שאפשר לקבל את ההרשאות הנדרשות גם באמצעות תפקידים בהתאמה אישית או תפקידים מוגדרים מראש.

    שימו לב שכברירת מחדל, ההרשאות של Cloud Build כוללות הרשאות להעלאה ולהורדה של פריטי מידע שנוצרו ב-Artifact Registry.

התפקידים הנדרשים לזהות הטריגר

  1. שימו לב לחשבון השירות שמוגדר כברירת מחדל ב-Compute Engine, כי תצטרכו לצרף אותו לטריגר של Eventarc כדי לייצג את הזהות של הטריגר לצורכי בדיקה. חשבון השירות הזה נוצר באופן אוטומטי אחרי שמפעילים שירות של Google Cloud שמשתמש ב-Compute Engine, או משתמשים בשירות כזה. כתובת האימייל שלו היא בפורמט הבא:

    PROJECT_NUMBER-compute@developer.gserviceaccount.com

    מחליפים את PROJECT_NUMBER במספר הפרויקט ב- Google Cloud. אפשר לראות את מספר הפרויקט בדף Welcome במסוף Google Cloud , או להריץ את הפקודה הבאה:

    gcloud projects describe PROJECT_ID --format='value(projectNumber)'

    בסביבות ייצור, מומלץ מאוד ליצור חשבון שירות חדש ולהקצות לו תפקיד אחד או יותר ב-IAM, שמכילים את ההרשאות המינימליות הנדרשות ופועלים לפי העיקרון של הרשאות מינימליות.

  2. כברירת מחדל, רק בעלי פרויקטים, עורכי פרויקטים, אדמינים של Cloud Run ומפעילים של Cloud Run יכולים להפעיל שירותי Cloud Run. אתם יכולים לשלוט בגישה לכל שירות בנפרד, אבל למטרות בדיקה, כדאי לתת לחשבון השירות של Compute Engine את התפקיד "מפעיל Cloud Run" (run.invoker) בפרויקט Google Cloud . כך מקצים את התפקיד בכל השירותים והמשימות של Cloud Run בפרויקט.
    gcloud projects add-iam-policy-binding PROJECT_ID \
        --member=serviceAccount:PROJECT_NUMBER-compute@developer.gserviceaccount.com \
        --role=roles/run.invoker

    שימו לב שאם יוצרים טריגר לשירות Cloud Run מאומת בלי להקצות את התפקיד Cloud Run Invoker, הטריגר נוצר בהצלחה והוא פעיל. עם זאת, הטריגר לא יפעל כמו שצריך ותופיע הודעה דומה לזו ביומנים:

    The request was not authenticated. Either allow public access or set the proper Authorization header.
  3. מקצים את התפקיד "מקבל אירועים ב-Eventarc" (roles/eventarc.eventReceiver) בפרויקט לחשבון השירות שמוגדר כברירת מחדל ב-Compute Engine, כדי שהטריגר של Eventarc יוכל לקבל אירועים מספקי אירועים.
    gcloud projects add-iam-policy-binding PROJECT_ID \
        --member=serviceAccount:PROJECT_NUMBER-compute@developer.gserviceaccount.com \
        --role=roles/eventarc.eventReceiver

תפקיד אופציונלי לסוכן השירות של Cloud Storage

  • לפני שיוצרים טריגר לאירועים ישירים מ-Cloud Storage, צריך לתת לסוכן השירות של Cloud Storage את התפקיד "פרסום הודעות ב-Pub/Sub" (roles/pubsub.publisher):

    SERVICE_ACCOUNT="$(gcloud storage service-agent --project=PROJECT_ID)"
    
    gcloud projects add-iam-policy-binding PROJECT_ID \
        --member="serviceAccount:${SERVICE_ACCOUNT}" \
        --role='roles/pubsub.publisher'

תפקיד אופציונלי לסוכן השירות של Pub/Sub

  • אם הפעלתם את סוכן השירות של Cloud Pub/Sub ב-8 באפריל 2021 או לפני כן, כדי לתמוך בבקשות דחיפה מאומתות של Pub/Sub, צריך להקצות לסוכן השירות את התפקיד "יצירת אסימונים בחשבון שירות" (roles/iam.serviceAccountTokenCreator). אחרת, התפקיד הזה מוקצה כברירת מחדל:
    gcloud projects add-iam-policy-binding PROJECT_ID \
        --member=serviceAccount:service-PROJECT_NUMBER@gcp-sa-pubsub.iam.gserviceaccount.com \
        --role=roles/iam.serviceAccountTokenCreator

יוצרים נושא Pub/Sub

כשפורסים פונקציה ב-Cloud Run, נושאי Pub/Sub לא נוצרים באופן אוטומטי. לפני פריסת הפונקציה, צריך לפרסם הודעה בנושא הזה ב-Pub/Sub כדי להפעיל את הפונקציה:

gcloud pubsub topics create YOUR_TOPIC_NAME

הכנת האפליקציה

  1. משכפלים את המאגר של האפליקציה לדוגמה ומעבירים אותו למכונה המקומית:

    Node.js

    git clone https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git
    

    Python

    git clone https://github.com/GoogleCloudPlatform/python-docs-samples.git
    

    Go

    git clone https://github.com/GoogleCloudPlatform/golang-samples.git
    

    Java

    git clone https://github.com/GoogleCloudPlatform/java-docs-samples.git
    

    ‎.NET

    git clone https://github.com/GoogleCloudPlatform/dotnet-docs-samples.git
    

    Ruby

    git clone https://github.com/GoogleCloudPlatform/ruby-docs-samples.git
    

    PHP

    git clone https://github.com/GoogleCloudPlatform/php-docs-samples.git
    
  2. עוברים לספרייה שמכילה את הקוד לדוגמה לגישה ל-Pub/Sub:

    Node.js

    cd nodejs-docs-samples/functions/v2/helloPubSub/
    

    Python

    cd python-docs-samples/functions/v2/pubsub/
    

    Go

    cd golang-samples/functions/functionsv2/hellopubsub/
    

    Java

    cd java-docs-samples/functions/v2/pubsub/
    

    ‎.NET

    cd dotnet-docs-samples/functions/helloworld/HelloPubSub/
    

    Ruby

    cd ruby-docs-samples/functions/helloworld/pubsub/
    

    PHP

    cd php-docs-samples/functions/helloworld_pubsub/
    
  3. הנה קוד לדוגמה:

    Node.js

    const functions = require('@google-cloud/functions-framework');
    
    // Register a CloudEvent callback with the Functions Framework that will
    // be executed when the Pub/Sub trigger topic receives a message.
    functions.cloudEvent('helloPubSub', cloudEvent => {
      // The Pub/Sub message is passed as the CloudEvent's data payload.
      const base64name = cloudEvent.data.message.data;
    
      const name = base64name
        ? Buffer.from(base64name, 'base64').toString()
        : 'World';
    
      console.log(`Hello, ${name}!`);
    });

    Python

    import base64
    
    from cloudevents.http import CloudEvent
    import functions_framework
    
    
    # Triggered from a message on a Cloud Pub/Sub topic.
    @functions_framework.cloud_event
    def subscribe(cloud_event: CloudEvent) -> None:
        # Print out the data from Pub/Sub, to prove that it worked
        print(
            "Hello, " + base64.b64decode(cloud_event.data["message"]["data"]).decode() + "!"
        )
    
    

    Go

    
    // Package helloworld provides a set of Cloud Functions samples.
    package helloworld
    
    import (
    	"context"
    	"fmt"
    	"log"
    
    	"github.com/GoogleCloudPlatform/functions-framework-go/functions"
    	"github.com/cloudevents/sdk-go/v2/event"
    )
    
    func init() {
    	functions.CloudEvent("HelloPubSub", helloPubSub)
    }
    
    // MessagePublishedData contains the full Pub/Sub message
    // See the documentation for more details:
    // https://cloud.google.com/eventarc/docs/cloudevents#pubsub
    type MessagePublishedData struct {
    	Message PubSubMessage
    }
    
    // PubSubMessage is the payload of a Pub/Sub event.
    // See the documentation for more details:
    // https://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage
    type PubSubMessage struct {
    	Data []byte `json:"data"`
    }
    
    // helloPubSub consumes a CloudEvent message and extracts the Pub/Sub message.
    func helloPubSub(ctx context.Context, e event.Event) error {
    	var msg MessagePublishedData
    	if err := e.DataAs(&msg); err != nil {
    		return fmt.Errorf("event.DataAs: %w", err)
    	}
    
    	name := string(msg.Message.Data) // Automatically decoded from base64.
    	if name == "" {
    		name = "World"
    	}
    	log.Printf("Hello, %s!", name)
    	return nil
    }
    

    Java

    import com.google.cloud.functions.CloudEventsFunction;
    import com.google.gson.Gson;
    import functions.eventpojos.PubSubBody;
    import io.cloudevents.CloudEvent;
    import java.nio.charset.StandardCharsets;
    import java.util.Base64;
    import java.util.logging.Logger;
    
    public class SubscribeToTopic implements CloudEventsFunction {
      private static final Logger logger = Logger.getLogger(SubscribeToTopic.class.getName());
    
      @Override
      public void accept(CloudEvent event) {
        // The Pub/Sub message is passed as the CloudEvent's data payload.
        if (event.getData() != null) {
          // Extract Cloud Event data and convert to PubSubBody
          String cloudEventData = new String(event.getData().toBytes(), StandardCharsets.UTF_8);
          Gson gson = new Gson();
          PubSubBody body = gson.fromJson(cloudEventData, PubSubBody.class);
          // Retrieve and decode PubSub message data
          String encodedData = body.getMessage().getData();
          String decodedData =
              new String(Base64.getDecoder().decode(encodedData), StandardCharsets.UTF_8);
          logger.info("Hello, " + decodedData + "!");
        }
      }
    }

    ‎.NET

    using CloudNative.CloudEvents;
    using Google.Cloud.Functions.Framework;
    using Google.Events.Protobuf.Cloud.PubSub.V1;
    using Microsoft.Extensions.Logging;
    using System.Threading;
    using System.Threading.Tasks;
    
    namespace HelloPubSub;
    
    public class Function : ICloudEventFunction<MessagePublishedData>
    {
        private readonly ILogger _logger;
    
        public Function(ILogger<Function> logger) =>
            _logger = logger;
    
        public Task HandleAsync(CloudEvent cloudEvent, MessagePublishedData data, CancellationToken cancellationToken)
        {
            string nameFromMessage = data.Message?.TextData;
            string name = string.IsNullOrEmpty(nameFromMessage) ? "world" : nameFromMessage;
            _logger.LogInformation("Hello {name}", name);
            return Task.CompletedTask;
        }
    }

    Ruby

    require "functions_framework"
    require "base64"
    
    FunctionsFramework.cloud_event "hello_pubsub" do |event|
      # The event parameter is a CloudEvents::Event::V1 object.
      # See https://cloudevents.github.io/sdk-ruby/latest/CloudEvents/Event/V1.html
      name = Base64.decode64 event.data["message"]["data"] rescue "World"
    
      # A cloud_event function does not return a response, but you can log messages
      # or cause side effects such as sending additional events.
      logger.info "Hello, #{name}!"
    end

    PHP

    
    use CloudEvents\V1\CloudEventInterface;
    use Google\CloudFunctions\FunctionsFramework;
    
    // Register the function with Functions Framework.
    // This enables omitting the `FUNCTIONS_SIGNATURE_TYPE=cloudevent` environment
    // variable when deploying. The `FUNCTION_TARGET` environment variable should
    // match the first parameter.
    FunctionsFramework::cloudEvent('helloworldPubsub', 'helloworldPubsub');
    
    function helloworldPubsub(CloudEventInterface $event): void
    {
        $log = fopen(getenv('LOGGER_OUTPUT') ?: 'php://stderr', 'wb');
    
        $cloudEventData = $event->getData();
        $pubSubData = base64_decode($cloudEventData['message']['data']);
    
        $name = $pubSubData ? htmlspecialchars($pubSubData) : 'World';
        fwrite($log, "Hello, $name!" . PHP_EOL);
    }

פריסת פונקציה מבוססת-אירועים

כדי לפרוס את הפונקציה, מריצים את הפקודה הבאה בספרייה שמכילה את הקוד לדוגמה:

Node.js

  gcloud run deploy FUNCTION \
        --source . \
        --function helloPubSub \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • ‫BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה nodejs24. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

Python

  gcloud run deploy FUNCTION \
        --source . \
        --function subscribe \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • ‫BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה python314. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

המשך

  gcloud run deploy FUNCTION \
        --source . \
        --function HelloPubSub \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה go127. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

Java

  gcloud run deploy FUNCTION \
        --source . \
        --function functions.SubscribeToTopic \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • ‫BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה java25. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

‎.NET

  gcloud run deploy FUNCTION \
        --source . \
        --function HelloPubSub.Function \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה dotnet10. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

Ruby

  gcloud run deploy FUNCTION \
        --source . \
        --function hello_pubsub \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה ruby40. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

PHP

  gcloud run deploy FUNCTION \
        --source . \
        --function helloworldPubsub \
        --base-image BASE_IMAGE \

מחליפים את:

  • ‫FUNCTION בשם הפונקציה שאתם פורסים. אם לא תציינו את הפרמטר הזה, תתבקשו להזין שם כשתריצו את הפקודה.
  • BASE_IMAGE בסביבת קובץ האימג' הבסיסי של הפונקציה, לדוגמה php85. למידע נוסף על קובצי אימג' בסיסיים ועל החבילות שכלולות בכל קובץ אימג', קראו את המאמר סביבות זמן ריצה של שפות נתמכות וקובצי אימג' בסיסיים.

אם תתבקשו ליצור מאגר באזור שצוין, הקישו על y. בסיום הפריסה, ב-Google Cloud CLI תוצג כתובת ה-URL שבה השירות פועל.

יצירת טריגר של Eventarc

כדי לפרוס את הפונקציה עם טריגר של Pub/Sub, מריצים את הפקודה הבאה בספרייה שמכילה את הקוד לדוגמה:

  1. יוצרים טריגר של Eventarc Pub/Sub:

    gcloud eventarc triggers create TRIGGER_NAME  \
        --location=${REGION} \
        --destination-run-service=FUNCTION \
        --destination-run-region=${REGION} \
        --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
        --service-account=PROJECT_NUMBER-compute@developer.gserviceaccount.com

    מחליפים את:

    • TRIGGER_NAME בשם של הטריגר.
    • FUNCTION בשם של הפונקציה.
    • ‫PROJECT_NUMBER במספר הפרויקט ב- Google Cloud .

    שימו לב: כשיוצרים טריגר של Eventarc בפעם הראשונה בפרויקט ב- Google Cloud , יכול להיות עיכוב בהקצאה של סוכן השירות של Eventarc. בדרך כלל אפשר לפתור את הבעיה הזו אם מנסים ליצור את הטריגר שוב. מידע נוסף זמין במאמר שגיאות של דחיית הרשאה.

  2. מוודאים שהטריגר נוצר בהצלחה. שימו לב: למרות שהטריגר נוצר באופן מיידי, יכול להיות שיעברו עד שתי דקות עד שהוא יפעל באופן מלא.

    gcloud eventarc triggers list --location=${REGION}

    הפלט אמור להיראות כך:

    NAME: helloworld-events
    TYPE: google.cloud.pubsub.topic.v1.messagePublished
    DESTINATION: Cloud Run service: helloworld-events
    ACTIVE: Yes
    LOCATION: us-central1
    

הפעלת הפונקציה

כדי לבדוק את הפונקציה של Pub/Sub:

  1. מקצים את הנושא למשתנה:

    TOPIC_ID=$(gcloud eventarc triggers describe TRIGGER_NAME --location $REGION --format='value(transport.pubsub.topic)')
    
  2. מפרסמים הודעה בנושא:

    gcloud pubsub topics publish $TOPIC_ID --message="Hello World"
    

שירות Cloud Run מתעד את גוף ההודעה הנכנסת. אפשר לראות את זה בקטע Logs של המכונה ב-Cloud Run:

  1. עוברים אל Google Cloud מסוף.
  2. לוחצים על הפונקציה.
  3. לוחצים על הכרטיסייה יומנים.

    יכול להיות שייקח ליומנים כמה דקות להופיע. אם הם לא מופיעים מיד, כדאי לבדוק שוב אחרי כמה דקות.

  4. מחפשים את ההודעה "Hello World!‎".

הסרת המשאבים

אם יצרתם פרויקט חדש בשביל המדריך הזה, מחקו את הפרויקט. אם השתמשתם בפרויקט קיים ואתם רוצים לשמור אותו בלי השינויים שנוספו במדריך הזה, מחקו את המשאבים שנוצרו בשביל המדריך.

מחיקת הפרויקט

הדרך הקלה ביותר לבטל את החיוב היא למחוק את הפרויקט שיצרתם בשביל המדריך הזה.

כדי למחוק את הפרויקט:

  1. במסוף Google Cloud , נכנסים לדף Manage resources.

    כניסה לדף Manage resources

  2. ברשימת הפרויקטים, בוחרים את הפרויקט שרוצים למחוק ולוחצים על Delete.
  3. כדי למחוק את הפרויקט, כותבים את מזהה הפרויקט בתיבת הדו-שיח ולוחצים על Shut down.

מחיקת משאבי המדריך

  1. מוחקים את השירות ב-Cloud Run שפרסתם במדריך הזה:

    gcloud run services delete SERVICE_NAME

    כאשר SERVICE_NAME הוא שם השירות שבחרתם.

    אפשר גם למחוק שירותי Cloud Run ממסוףGoogle Cloud .

  2. מסירים את כל הגדרות ברירת המחדל של ה-CLI של gcloud שהוספתם במהלך ההגדרה של המדריך.

    לדוגמה:

    gcloud config unset run/region

    או

    gcloud config unset project

  3. מוחקים משאבים אחרים של Google Cloud שנוצרו במדריך הזה:

    • מוחקים את הטריגר של Eventarc:
      gcloud eventarc triggers delete TRIGGER_NAME
      
      מחליפים את TRIGGER_NAME בשם הטריגר.

המאמרים הבאים