Ejecuta un trabajo de Cloud Run que procese los datos de eventos guardados en Cloud Storage

Console

1. En la consola de Google Cloud, ve a la página Flujos de trabajo:

   Ir a Workflows

2. Haz clic en add Crear.

3. Ingresa un nombre para el flujo de trabajo nuevo, como message-payload-workflow.

4. Elige una región adecuada, por ejemplo, us-central1.

5. En el campo Cuenta de servicio, selecciona la cuenta de servicio que creaste antes.

   La cuenta de servicio funciona como la identidad del flujo de trabajo. Ya deberías haber otorgado los siguientes roles a la cuenta de servicio:

   • Administrador de Cloud Run: Para ejecutar trabajos de Cloud Run
   • Escritor de registros: Para escribir entradas de registro
   • Creador de objetos de almacenamiento: Para crear objetos en Cloud Storage

6. Haz clic en Siguiente.

7. En el editor de flujos de trabajo, ingresa la siguiente definición para tu flujo de trabajo:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: ${"message-payload-" + project_id}
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

8. Haz clic en Implementar.

gcloud

1. Crea un archivo de código fuente para tu flujo de trabajo:

   touch message-payload-workflow.yaml

2. Copia la siguiente definición de flujo de trabajo en message-payload-workflow.yaml:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: ${"message-payload-" + project_id}
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

3. Para implementar el flujo de trabajo, ingresa el siguiente comando:

   gcloud workflows deploy message-payload-workflow \
       --location=us-central1 \
       --source=message-payload-workflow.yaml \
       --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

   Reemplaza lo siguiente:

   • SERVICE_ACCOUNT_NAME: Es el nombre de la cuenta de servicio que creaste antes.
   • PROJECT_ID: El ID de tu proyecto de Google Cloud

   La cuenta de servicio funciona como la identidad del flujo de trabajo. Ya deberías haber otorgado los siguientes roles a la cuenta de servicio:

   • roles/logging.logWriter: Para escribir entradas de registro
   • roles/run.admin: Para ejecutar trabajos de Cloud Run
   • roles/storage.objectCreator: Para crear objetos en Cloud Storage

Console

1. En la consola de Google Cloud, ve a la página Temas.

   Ir a temas

2. Haz clic en add Crear tema.

3. En el campo ID de tema, ingresa un ID para el tema, como message-payload-topic.

4. Mantén la opción Agregar una suscripción predeterminada.

5. No selecciones las otras opciones.

6. Haz clic en Crear.

gcloud

Para crear un tema con el ID message-payload-topic, ejecuta el comando gcloud pubsub topics create:

gcloud pubsub topics create message-payload-topic

Console

1. En la consola de Google Cloud, ve a la página Flujos de trabajo:

   Ir a Workflows

2. Haz clic en el nombre de tu flujo de trabajo, como message-payload-workflow.

3. En la página Detalles del flujo de trabajo, haz clic en edit Editar.

4. En la página Editar flujo de trabajo, en la sección Activadores, haz clic en Agregar activador nuevo > Eventarc.

   Se abrirá el panel Evento de Eventarc.

5. En el campo Nombre del activador, ingresa un nombre para el activador, como message-payload-trigger.

6. En la lista Proveedor de eventos, selecciona Cloud Pub/Sub.

7. En la lista Evento, selecciona google.cloud.pubsub.topic.v1.messagePublished.

8. En la lista Selecciona un tema de Cloud Pub/Sub, selecciona el tema de Pub/Sub que creaste antes.

9. En el campo Cuenta de servicio, selecciona la cuenta de servicio que creaste antes.

   La cuenta de servicio funciona como la identidad del activador. Ya deberías haber otorgado los siguientes roles a la cuenta de servicio:

   • Receptor de eventos de Eventarc: Para recibir eventos
   • Invocador de flujos de trabajo: Para ejecutar flujos de trabajo

10. Haz clic en Guardar activador.

    El activador de Eventarc ahora aparece en la sección Activadores de la página Editar flujo de trabajo.

11. Haz clic en Siguiente.

12. Haz clic en Implementar.

gcloud

Ejecuta el siguiente comando para crear un activador de Eventarc:

gcloud eventarc triggers create message-payload-trigger \
    --location=us-central1 \
    --destination-workflow=message-payload-workflow \
    --destination-workflow-location=us-central1 \
    --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
    --transport-topic=projects/PROJECT_ID/topics/message-payload-topic \
    --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

Reemplaza lo siguiente:

• PROJECT_IDEl ID de tu proyecto de Google Cloud.
• SERVICE_ACCOUNT_NAME: Es el nombre de la cuenta de servicio que creaste antes.

La cuenta de servicio funciona como la identidad del activador. Ya deberías haber otorgado los siguientes roles a la cuenta de servicio:

• roles/eventarc.eventReceiver: Para recibir eventos
• roles/workflows.invoker: Para ejecutar flujos de trabajo