Publica eventos en un trabajo de Cloud Run

Publica eventos en un trabajo de Cloud Run

Avanzado

En esta guía de inicio rápido, se muestra cómo publicar y recibir mensajes de eventos creando un bus de Eventarc Advanced y una inscripción en tu proyecto de Google Cloud.

• Un bus actúa como un enrutador central que recibe mensajes de fuentes de eventos o que publican los proveedores.

• Una inscripción enruta los mensajes que recibe el bus a uno o más destinos a través de una canalización de procesamiento.

En esta guía de inicio rápido, podrás hacer lo siguiente:

1. Implementa un trabajo de Cloud Run desde el código fuente.

2. Crea un bus de Eventarc Advanced.

3. Crea una inscripción en Eventarc Advanced.

4. Publica un mensaje de evento en el bus.

5. Confirma que el trabajo de Cloud Run se haya ejecutado correctamente.

Puedes completar esta guía de inicio rápido con gcloud CLI.

Antes de comenzar

Es posible que las restricciones de seguridad que define tu organización no te permitan completar los siguientes pasos. Para obtener información sobre la solución de problemas, consulta Desarrolla aplicaciones en un entorno de Google Cloud restringido.

Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.

Install the Google Cloud CLI.

Si usas un proveedor de identidad externo (IdP), primero debes acceder a la gcloud CLI con tu identidad federada.

Para inicializar gcloud CLI, ejecuta el siguiente comando:

gcloud init

Create or select a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

• Create a Google Cloud project:

  gcloud projects create PROJECT_ID

  Replace PROJECT_ID with a name for the Google Cloud project you are creating.

• Select the Google Cloud project that you created:

  gcloud config set project PROJECT_ID

  Replace PROJECT_ID with your Google Cloud project name.

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run and Eventarc APIs:

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com eventarc.googleapis.com eventarcpublishing.googleapis.com run.googleapis.com 

Install the Google Cloud CLI.

Si usas un proveedor de identidad externo (IdP), primero debes acceder a la gcloud CLI con tu identidad federada.

Para inicializar gcloud CLI, ejecuta el siguiente comando:

gcloud init

Create or select a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

• Create a Google Cloud project:

  gcloud projects create PROJECT_ID

  Replace PROJECT_ID with a name for the Google Cloud project you are creating.

• Select the Google Cloud project that you created:

  gcloud config set project PROJECT_ID

  Replace PROJECT_ID with your Google Cloud project name.

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run and Eventarc APIs:

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com eventarc.googleapis.com eventarcpublishing.googleapis.com run.googleapis.com 

1. Actualiza los componentes de gcloud:

   gcloud components update

2. Accede con tu cuenta:

   gcloud auth login

3. Establece la variable de configuración que se usa en esta guía de inicio rápido:

   REGION=REGION

   Reemplaza REGION por una ubicación compatible para el autobús, por ejemplo, us-central1.

4. Si eres el creador del proyecto, se te otorga el rol de propietario básico (roles/owner). De forma predeterminada, este rol de Identity and Access Management (IAM) incluye los permisos necesarios para obtener acceso completo a la mayoría de los recursos de Google Cloud y puedes omitir este paso.

   Si no eres el creador del proyecto, se deben otorgar los permisos necesarios en el proyecto a la principal correspondiente. Por ejemplo, una principal puede ser una Cuenta de Google (para usuarios finales) o una cuenta de servicio (para aplicaciones y cargas de trabajo de procesamiento).

   Permisos necesarios

   Si quieres obtener los permisos que necesitas para completar esta guía de inicio rápido, pídele a tu administrador que te otorgue los siguientes roles de IAM en tu proyecto:

   • Desarrollador de Cloud Run (roles/run.developer)
   • Desarrollador de Eventarc (roles/eventarc.developer)
   • Administrador de buses de mensajes de Eventarc (roles/eventarc.messageBusAdmin)
   • Descriptor de acceso de vista de registros (roles/logging.viewAccessor)
   • Administrador de IAM de proyecto (roles/resourcemanager.projectIamAdmin)
   • Administrador de cuenta de servicio (roles/iam.serviceAccountAdmin)
   • Usuario de la cuenta de servicio (roles/iam.serviceAccountUser)
   • Administrador de Service Usage (roles/serviceusage.serviceUsageAdmin)

   Para obtener más información sobre cómo otorgar roles, consulta Administra el acceso a proyectos, carpetas y organizaciones.

   También puedes obtener los permisos necesarios a través de roles personalizados o cualquier otro rol predefinido.

5. Para otorgarle a Eventarc Advanced los permisos necesarios para ejecutar un trabajo de Cloud Run, pídele a tu administrador que otorgue el rol de IAM de invocador de Cloud Run (roles/run.invoker) en tu proyectoGoogle Cloud a una cuenta de servicio:
   1. Crea una cuenta de servicio. Para realizar pruebas, conectarás esta cuenta de servicio a una canalización de Eventarc Advanced para representar la identidad de la canalización.

      gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

      Reemplaza SERVICE_ACCOUNT_NAME por un nombre para tu cuenta de servicio.
   2. Otorga el rol de IAM roles/run.invoker a la cuenta de servicio:

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" \
          --role=roles/run.invoker

Implementa un trabajo de Cloud Run desde el código fuente

Implementa un trabajo de Cloud Run como destino del evento. A diferencia de un servicio de Cloud Run, que escucha y entrega solicitudes, un trabajo de Cloud Run solo ejecuta sus tareas y se cierra cuando finaliza. Un trabajo no escucha ni entrega solicitudes.

Se admiten otros destinos de eventos, como un tema de Pub/Sub, Workflows o algún otro extremo HTTP. Para obtener más información, consulta Proveedores y destinos de eventos.

Crea un trabajo a partir del código fuente de Python con el comando gcloud run jobs deploy. Tu código se empaqueta automáticamente en una imagen de contenedor, se sube a Artifact Registry y, luego, se implementa en Cloud Run.

1. Crea un directorio llamado jobs y navega hasta él:

   mkdir jobs
   cd jobs
   

2. Crea un archivo main.py y copia el siguiente código de muestra en él:

   import os
   
   TASK_INDEX = os.getenv("CLOUD_RUN_TASK_INDEX", 0)
   
   def main():
       """
       This job prints "Hello world"
       """
       print(f"Starting task #{TASK_INDEX}...")
       print("Hello world")
       print(f"Completed task #{TASK_INDEX}.")
   
   # Start script
   if __name__ == "__main__":
       main()
   

3. Crea un archivo de texto llamado Procfile sin extensión y copia el siguiente texto en él:

   web: python3 main.py
   

4. Implementa el trabajo:

   gcloud run jobs deploy JOB_NAME \
       --source . \
       --tasks 1 \
       --region=$REGION

   Reemplaza JOB_NAME por un nombre único para el trabajo de Cloud Run, por ejemplo, my-job.

Crea un bus de Eventarc Advanced

Un bus recibe mensajes de eventos de una fuente de mensajes o publicados por un proveedor y actúa como un router de mensajes.

Para obtener más información, consulta Crea un bus para enrutar mensajes.

Nota: Puedes crear un bus por Google Cloud proyecto porregión admitida.

Crea un bus de Eventarc Advanced en tu proyecto con el comando gcloud eventarc message-buses create:

gcloud eventarc message-buses create BUS_NAME \
    --location=$REGION

Reemplaza BUS_NAME por el ID de tu bus o un nombre completamente calificado, por ejemplo, my-bus.

Crea una inscripción en Eventarc Advanced

Una inscripción determina qué mensajes se enrutan a un destino. También especifica la canalización que se usa para configurar el destino de los mensajes de eventos. En este caso, el destino es un trabajo de Cloud Run.

Para obtener más información, consulta Cómo crear un registro para recibir eventos.

Nota: La creación de una canalización puede tardar más de 10 minutos.

Cuando usas gcloud CLI, primero creas una canalización y, luego, creas una inscripción:

1. Crea una canalización con el comando gcloud eventarc pipelines create:

   gcloud eventarc pipelines create PIPELINE_NAME \
       --destinations=http_endpoint_uri='https://REGION-run.googleapis.com/apis/run.googleapis.com/v1/namespaces/PROJECT_NUMBER/jobs/JOB_NAME:run',http_endpoint_message_binding_template='{"body": ""}',oauth_token_authentication_service_account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com \
       --input-payload-format-json= \
       --location=$REGION

   Reemplaza lo siguiente:

   • PIPELINE_NAME: Es el ID de la canalización o un nombre completamente calificado, por ejemplo, my-pipeline.
   • PROJECT_NUMBER: Es el número de tu proyecto de Google Cloud . Para recuperar el número de tu proyecto, ejecuta el siguiente comando:

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

   Ten en cuenta lo siguiente:

   • La clave http_endpoint_message_binding_template transforma el evento en el formato que espera la API de Cloud Run Admin. Cuando defines una vinculación de mensajes, debes configurar un formato de entrada para acceder a la carga útil.
   • La clave oauth_token_authentication_service_account especifica un correo electrónico de cuenta de servicio. Esta dirección de correo electrónico se usa para generar un token de OAuth que, por lo general, solo se usa cuando se llama a las APIs de Google alojadas en *.googleapis.com.

2. Crea una inscripción con el comando gcloud eventarc enrollments create:

   gcloud eventarc enrollments create ENROLLMENT_NAME \
       --cel-match=MATCH_EXPRESSION \
       --destination-pipeline=PIPELINE_NAME \
       --message-bus=BUS_NAME \
       --message-bus-project=PROJECT_ID \
       --location=$REGION

   Reemplaza lo siguiente:

   • ENROLLMENT_NAME: Es el ID de la inscripción o un nombre completamente calificado, por ejemplo, my-enrollment.

   • MATCH_EXPRESSION: Es la expresión de coincidencia para esta inscripción con CEL. Por ejemplo:

     "message.type == 'hello-world-type'"
     

Publica un mensaje de evento en el bus

Para publicar un mensaje directamente en tu bus, usa el comando gcloud eventarc message-buses publish o envía una solicitud a la API de REST de Eventarc Publishing. Para obtener más información, consulta Cómo publicar eventos directamente.

El mensaje debe estar en formato CloudEvents, una especificación para describir los datos de eventos de una manera común. El elemento data es la carga útil de tu evento. En este campo, se puede incluir cualquier JSON bien formado. Para obtener más información sobre los atributos de contexto de CloudEvents, consulta Formato de evento.

A continuación, se muestran ejemplos de cómo publicar directamente un evento en un bus de Eventarc Advanced:

Ejemplo 1

Publica un evento en un bus con gcloud CLI y --event-data y otras marcas de atributos de eventos:

gcloud eventarc message-buses publish BUS_NAME \
    --event-data='{"key": "hello-world-data"}' \
    --event-id=hello-world-id-1234 \
    --event-source=hello-world-source \
    --event-type=hello-world-type \
    --event-attributes="datacontenttype=application/json" \
    --location=$REGION

Ejemplo 2

Publica un evento en un bus como un mensaje JSON con gcloud CLI y una marca --json-message:

gcloud eventarc message-buses publish BUS_NAME \
    --location=$REGION \
    --json-message='{"id": "hello-world-id-1234", "type":
 "hello-world-type", "source":
 "hello-world-source", "specversion": "1.0", "data":
 {"key": "hello-world-data"}}'

Después de publicar un evento, deberías recibir un mensaje que diga "Se publicó el evento correctamente".

Confirma que el trabajo de Cloud Run se haya ejecutado correctamente

Después de publicar un evento en tu bus avanzado de Eventarc, verifica los registros de tu trabajo de Cloud Run para comprobar que se ejecutó correctamente y que se imprimió "Hello world". Es posible que el trabajo tarde unos minutos en ejecutarse y completarse.

1. Filtra las entradas de registro y muestra el resultado con el comando gcloud logging read:

   gcloud logging read 'textPayload: "Hello world"'
   

2. Busca una entrada de registro similar a la que se muestra a continuación:

   insertId: 693c8dd0000cb2976d7966b8
   ...
   labels:
       job_name: JOB_NAME
       location: REGION
       project_id: PROJECT_ID
   type: cloud_run_job
   textPayload: Hello world
   timestamp: '2025-12-12T21:49:04.832151Z'
   

   Nota: Si no ves una entrada de registro, espera unos minutos y vuelve a ejecutar el comando gcloud logging read.

3. También puedes confirmar que el trabajo de Cloud Run se ejecutó correctamente con el comando gcloud run jobs describe:

   gcloud run jobs describe JOB_NAME \
       --region=$REGION
   

   Deberías recibir un resultado similar al siguiente.

   ✔ Job JOB_NAME in region us-central1
   Executed 1 time
   ...
   

Creaste correctamente un bus y una inscripción de Eventarc Advanced, publicaste un mensaje de evento en el bus y verificaste el resultado esperado en los registros del receptor de eventos.

Realiza una limpieza

Para evitar que se te siga facturando después de completar esta guía de inicio rápido, borra los recursos que creaste:

1. Borra un trabajo de Cloud Run.

2. Borra los recursos de Eventarc Advanced:

   1. Borra una inscripción.

   2. Borra una canalización.

   3. Borra un autobús.

Como alternativa, borra tu Google Cloud proyecto para evitar que se generen cargos. Si borras tu proyecto de Google Cloud , se detendrá la facturación de todos los recursos que se usaron en él.

Precaución: Borrar un proyecto tiene las siguientes consecuencias:

• Se borra todo su contenido. Si usaste un proyecto existente para las tareas de este documento, cuando lo borres, también se borrará cualquier otro trabajo que hayas realizado en el proyecto.
• Se pierden los IDs personalizados de los proyectos. Cuando creaste este proyecto, es posible que hayas creado un ID personalizado del proyecto que desees utilizar en el futuro. Para conservar las URLs que usan el ID del proyecto, como una URL appspot.com, borra los recursos seleccionados dentro del proyecto, en lugar de todo el proyecto.

Si planeas explorar varios instructivos, arquitecturas o guías de inicio rápido, reutilizar proyectos puede ser útil para no exceder los límites de cuota de los proyectos.

Delete a Google Cloud project:

gcloud projects delete PROJECT_ID

¿Qué sigue?

• Publica eventos de fuentes de Google
• Publica eventos directamente
• Transforma los eventos recibidos
• Cómo dar formato a los eventos recibidos