Recibe eventos mediante mensajes de Pub/Sub (CLI de gcloud)
En esta guía de inicio rápido, se muestra cómo configurar un servicio de Google Kubernetes Engine (GKE) como destino para recibir eventos de temas de Pub/Sub mediante Eventarc.
En esta guía de inicio rápido, podrás hacer lo siguiente:
- Completa tareas, como habilitar las APIs y configurar una cuenta de servicio.
- Crear un clúster de GKE
- Inicializar los destinos de GKE en Eventarc
- Implementar un servicio de GKE que reciba eventos.
- Crear un activador de Eventarc que conecte un tema de Pub/Sub al servicio de GKE.
- Generar y visualizar un evento de Pub/Sub
Antes de comenzar
- 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.
-
To initialize the gcloud CLI, run the following command:
gcloud init
-
Create or select a Google Cloud 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.
-
-
Make sure that billing is enabled for your Google Cloud project.
- Install the Google Cloud CLI.
-
To initialize the gcloud CLI, run the following command:
gcloud init
-
Create or select a Google Cloud 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.
-
-
Make sure that billing is enabled for your Google Cloud project.
- Actualiza los componentes de Google Cloud CLI:
gcloud components update
- Habilita las APIs de Eventarc, Resource Manager y Google Kubernetes Engine:
gcloud services enable eventarc.googleapis.com \ cloudresourcemanager.googleapis.com \ container.googleapis.com
- Establece las variables de configuración que se usan en esta guía de inicio rápido:
PROJECT_ID=$(gcloud config get-value project) CLUSTER_NAME=events-cluster SERVICE_NAME=hello-gke LOCATION=us-central1
-
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, pero 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). Para obtener más información, consulta la página Roles y permisos para el destino del evento.
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:
-
Administrador de Eventarc (
roles/eventarc.admin
) -
Administrador de Kubernetes Engine (
roles/container.admin
) -
Descriptor de acceso de vista de registros (
roles/logging.viewAccessor
) -
Administrador de IAM de proyecto (
roles/resourcemanager.projectIamAdmin
) -
Publicador de Pub/Sub (
roles/pubsub.publisher
) -
Administrador de cuenta de servicio (
roles/iam.serviceAccountAdmin
) -
Usuario de 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 mediante roles personalizados o cualquier otro rol predefinido.
-
Administrador de Eventarc (
Toma nota del recurso Compute Engine predeterminada, ya que la conectarás a un activador de Eventarc para representar la identidad del activador con fines de prueba. Esta cuenta de servicio se crea automáticamente después de habilitar o usar un servicio de Google Cloud que use Compute Engine, y con la siguiente formato de correo electrónico:
PROJECT_NUMBER-compute@developer.gserviceaccount.com
Reemplaza
PROJECT_NUMBER
por el número de proyecto de Google Cloud. Para encontrar el número del proyecto, ve a la página de bienvenida de la consola de Google Cloud o ejecuta el siguiente comando:gcloud projects describe PROJECT_ID --format='value(projectNumber)'
Para entornos de producción, recomendamos crear una cuenta de servicio nueva y otorgarle una o más funciones de IAM que contengan los permisos mínimos requeridos y seguir el principio de privilegio mínimo.
- Otorga el
rol de suscriptor
de Pub/Sub (
roles/pubsub.subscriber
) en el proyecto a la cuenta de servicio predeterminada de Compute Engine para que el activador de Eventarc pueda extraer eventos desde Pub/Sub.gcloud projects add-iam-policy-binding PROJECT_ID \ --member=serviceAccount:PROJECT_NUMBER-compute@developer.gserviceaccount.com \ --role=roles/pubsub.subscriber
- Si habilitaste el agente de servicio de Cloud Pub/Sub el 8 de abril de 2021 o antes de esa fecha,
para admitir las solicitudes de envío de Pub/Sub autenticadas, otorga
el rol de creador
de tokens de cuenta de servicio (
roles/iam.serviceAccountTokenCreator
) al agente de servicio. De lo contrario, este rol se otorga de forma predeterminada:gcloud projects add-iam-policy-binding PROJECT_ID \ --member=serviceAccount:service-PROJECT_NUMBER@gcp-sa-pubsub.iam.gserviceaccount.com \ --role=roles/iam.serviceAccountTokenCreator
Crea un clúster de GKE
Un clúster consta de al menos una máquina de plano de control y varias máquinas trabajadoras llamadas nodos. Los nodos son instancias de máquinas virtuales (VM) de Compute Engine que ejecutan los procesos de Kubernetes necesarios para que sean parte del clúster. Las aplicaciones se implementan en los clústeres y se ejecutan en los nodos.
Crea un clúster de Autopilot con el nombreevents-cluster
:
gcloud container clusters create-auto $CLUSTER_NAME \ --region $LOCATION
La creación del clúster puede tardar varios minutos en completarse. Una vez que se crea el clúster, el resultado debe ser similar al siguiente:
Creating cluster events-cluster...done.
Created [https://container.googleapis.com/v1/projects/MY_PROJECT
/zones/us-central1/clusters/events-cluster].
[...]
STATUS: RUNNING
Esto crea un clúster de GKE llamado events-cluster
en un proyecto con un ID del proyecto de Google Cloud de MY_PROJECT
.
Habilita los destinos de GKE
Para cada activador que se orienta a un servicio de GKE, Eventarc crea un componente de reenvío de eventos que extrae eventos de Pub/Sub y los reenvía al destino. Para crear el componente y administrar los recursos en el clúster de GKE, otorga permisos al agente de servicio de Eventarc:
Habilita los destinos de GKE para Eventarc:
gcloud eventarc gke-destinations init
Cuando se te solicite vincular los roles necesarios, ingresa
y
.Los siguientes roles están vinculados a la cuenta de servicio:
compute.viewer
container.developer
iam.serviceAccountAdmin
Crea un destino de servicio de GKE
Implementa un servicio de GKE que reciba y registre eventos con una imagen compilada con anterioridad, us-docker.pkg.dev/cloudrun/container/hello
:
Kubernetes usa un archivo YAML llamado
kubeconfig
a fin de almacenar información de autenticación de clúster parakubectl
. Actualiza el archivokubeconfig
con credenciales y la información del extremo para apuntar akubectl
en el clúster de GKE:gcloud container clusters get-credentials $CLUSTER_NAME \ --region $LOCATION
Crea una Deployment de Kubernetes:
kubectl create deployment $SERVICE_NAME \ --image=us-docker.pkg.dev/cloudrun/container/hello
Exponlo como un servicio de Kubernetes:
kubectl expose deployment $SERVICE_NAME \ --type ClusterIP \ --port 80 \ --target-port 8080
Crea un activador de Eventarc
Cuando se publica un mensaje en el tema de Pub/Sub, el activador de Eventarc envía mensajes al servicio hello-gke
de GKE.
Crea un activador GKE para detectar los mensajes de Pub/Sub:
Nuevo tema Pub/Sub
gcloud eventarc triggers create gke-trigger-pubsub \ --location="$LOCATION" \ --destination-gke-cluster=$CLUSTER_NAME \ --destination-gke-location=$LOCATION \ --destination-gke-namespace=default \ --destination-gke-service=$SERVICE_NAME \ --destination-gke-path=/ \ --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \ --service-account="PROJECT_NUMBER-compute@developer.gserviceaccount.com"
Esto crea un nuevo tema de Pub/Sub y un activador llamado
gke-trigger-pubsub
para este.Tema de Pub/Sub existente
gcloud eventarc triggers create gke-trigger-pubsub \ --location="$LOCATION" \ --destination-gke-cluster=$CLUSTER_NAME \ --destination-gke-location=$LOCATION \ --destination-gke-namespace=default \ --destination-gke-service=$SERVICE_NAME \ --destination-gke-path=/ \ --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \ --service-account="PROJECT_NUMBER-compute@developer.gserviceaccount.com" \ --transport-topic=projects/PROJECT_ID/topics/TOPIC_ID
Reemplaza lo siguiente:
PROJECT_ID
: ID del proyecto de Google Cloud.TOPIC_ID
: el ID del tema de Pub/Sub existente Esto crea un activador llamadogke-trigger-pubsub
para el tema de Pub/Sub existente.
Confirma que el activador se haya creado de forma correcta: Pueden pasar hasta dos minutos hasta que el activador funcione por completo.
gcloud eventarc triggers list
El resultado debería ser similar al siguiente ejemplo:
NAME: gke-trigger-pubsub TYPE: google.cloud.pubsub.topic.v1.messagePublished DESTINATION: GKE: hello-gke ACTIVE: Yes LOCATION: us-central1
Genera y visualiza un evento
Puedes generar un evento para activar el servicio de GKE si publicas un mensaje en el tema de Pub/Sub. Luego, puedes ver el mensaje en los registros del Pod.
Busca y establece el tema Pub/Sub como una variable de entorno:
TOPIC=$(gcloud eventarc triggers describe gke-trigger-pubsub \ --location=us-central1 \ --format='value(transport.pubsub.topic)')
Envía un mensaje al tema de Pub/Sub para generar un evento:
gcloud pubsub topics publish $TOPIC --message="Hello World"
El servicio de GKE registra el mensaje del evento.
Para ver el mensaje del evento, sigue estos pasos:
Busca el ID del Pod:
kubectl get pods
El resultado debería ser similar al siguiente ejemplo:
NAME READY STATUS RESTARTS AGE hello-gke-645964f578-2mjjt 1/1 Running 0 35s
Copia el
NAME
del pod para usarlo en el siguiente paso.Verifica los registros del Pod:
kubectl logs NAME
Reemplaza
NAME
por el nombre del Pod que copiaste.Busca una entrada de registro similar a lo siguiente:
2022/02/24 22:23:49 Hello from Cloud Run! The container started successfully and is listening for HTTP requests on $PORT {"severity":"INFO","eventType":"google.cloud.pubsub.topic.v1.messagePublished","message":"Received event of type google.cloud.pubsub.topic.v1.messagePublished. Event data: Hello World"[...]}
Realiza una limpieza
Cuando finalices las tareas que se describen en este documento, puedes borrar los recursos que creaste para evitar que continúe la facturación.
Puedes hacer lo siguiente:
Borrar el activador de Eventarc.
Esta acción también borra el tema de Pub/Sub asociado.
Como alternativa, puedes borrar el proyecto de Cloud para evitar que se generen cargos. Si borras tu proyecto de Google Cloud, se dejan de facturar todos los recursos que usaste en ese proyecto.
Delete a Google Cloud project:
gcloud projects delete PROJECT_ID
Si planeas explorar varios instructivos y guías de inicio rápido, la reutilización de proyectos puede ayudarte a evitar exceder los límites de las cuotas del proyecto.
¿Qué sigue?
Recibir eventos con los Registros de auditoría de Cloud (Google Cloud CLI)