Attivare la notifica degli eventi del modello con Cloud Functions e Pub/Sub

Mantieni tutto organizzato con le raccolte Salva e classifica i contenuti in base alle tue preferenze.

1. Ascolta i dati del modello e genera eventi utilizzando le funzioni Cloud Run.
2. Invia gli eventi generati dalle funzioni Cloud Run tramite il canale di eventi Pub/Sub.

Modelli supportati

I seguenti modelli offrono la generazione di eventi delle funzioni Cloud Run e le integrazioni di notifiche di eventi Pub/Sub:

• Modello di analisi delle presenze
• Modelli addestrati personalizzati di Vertex AI

Prima di iniziare

• Crea un'app con almeno un nodo stream e un nodo modello supportato.
• Facoltativo. Installa l'SDK Vertex AI Vision e importa i dati nella tua app. Se non lo fai prima di configurare la notifica degli eventi, devi farlo dopo.
• Facoltativo. Crea una funzione Cloud Run da utilizzare. Se non crei la funzione Cloud Run prima di configurare le funzioni Cloud Run per elaborare l'output del modello, devi crearla durante questo processo.
• Facoltativo. Crea un argomento Pub/Sub da utilizzare. Se non crei l'argomento Pub/Sub prima di attivare la notifica degli eventi del modello con Pub/Sub, devi crearlo durante la procedura.
• Facoltativo. Scegli e crea una sottoscrizione Pub/Sub. Se non crei la sottoscrizione Pub/Sub prima di attivare la notifica degli eventi del modello con Pub/Sub, devi crearla dopo per leggere i messaggi da un argomento.

Configura le funzioni Cloud Run per elaborare l'output del modello

Per attivare le notifiche basate su eventi, devi prima configurare le funzioni Cloud Run per elaborare l'output del modello e generare eventi.

La funzione Cloud Run si connette al modello e ne ascolta l'output come azione di post-elaborazione. La funzione Cloud Run deve restituire un AppPlatformCloudFunctionResponse. Gli eventi (appplatformeventbody) vengono inviati all'argomento Pub/Sub che configuri nel passaggio successivo.

Funzione Cloud Run di esempio (modello di analisi dell'occupazione)

/**
* Responds to any HTTP request.
*
* @param {!express:Request} req HTTP request context.
* @param {!express:Response} res HTTP response context.
*/
exports.hello_http = (req, res) => {
// Logging statement can be read with cmd `gcloud functions logs read {$functionName}`.
// For more about logging, please see https://cloud.google.com/functions/docs/monitoring

// The processor output will be stored in req.body.
const messageString = constructMessage(req.body);

// Send your message to operator output with res HTTP response context.
res.status(200).send(messageString);
};

function constructMessage(data) {
// Typically, your processor output should contains appPlatformMetadata & it's designed output.
// Here we will use the occupancy analytics model as an example.
const appPlatformMetadata = data.appPlatformMetadata;
const annotations = data.annotations;
const events = [];
for(const annotation of annotations) {
   events.push({
      "event_message": "Event message goes here",
      "payload" : {
         "attr_key_goes_here" : "val_goes_here"
      },
      "event_id" : "event_id_goes_here"
   });
}

// Typically, your cloud function should return a string represent a JSON which has two fields:
// "annotations" must follow the specification of the target model.
// "events" should be of type "AppPlatformEventBody".
const messageJson = {
   "annotations": annotations,
   "events": events,
};
return JSON.stringify(messageJson);
}

Segui le istruzioni riportate di seguito per inviare lo stream di output del modello alla funzione Cloud Run:

Attivare la notifica degli eventi del modello con Pub/Sub

Dopo aver configurato le funzioni Cloud Run per elaborare l'output del modello e generare eventi, puoi configurare la notifica degli eventi con Pub/Sub. Per leggere i messaggi da un argomento, devi anche scegliere e creare una sottoscrizione Pub/Sub.

Passaggi successivi

• Leggi le istruzioni su come eseguire il deployment dell'app per testare la notifica evento del modello in Eseguire il deployment e annullare il deployment di un'applicazione.
• Segui il codelab sull'app Vertex AI Vision Occupancy Analytics con gestione degli eventi.
• Scopri di più su Pub/Sub e Cloud Run Functions in Che cos'è Pub/Sub? e nella panoramica di Cloud Run Functions.