Questo documento mostra come associare gli schemi per gli argomenti Pub/Sub.
Prima di iniziare
- Scopri come funzionano gli schemi Pub/Sub.
- Crea uno schema.
Autorizzazioni e ruoli richiesti
Per ottenere le autorizzazioni necessarie per associare e gestire gli schemi,
chiedi all'amministratore di concederti il ruolo IAM
Editor Pub/Sub (roles/pubsub.editor
) per il tuo progetto.
Per saperne di più sulla concessione dei ruoli, consulta Gestire l'accesso.
Questo ruolo predefinito contiene le autorizzazioni necessarie per associare e gestire gli schemi. Per visualizzare le autorizzazioni esatte necessarie, espandi la sezione Autorizzazioni richieste:
Autorizzazioni obbligatorie
Per associare e gestire gli schemi sono necessarie le seguenti autorizzazioni:
-
Crea schema:
pubsub.schemas.create
-
Collega schema all'argomento:
pubsub.schemas.attach
-
Esegui il commit di una revisione dello schema:
pubsub.schemas.commit
-
Elimina uno schema o una revisione di uno schema:
pubsub.schemas.delete
-
Visualizza le revisioni di uno schema o di uno schema:
pubsub.schemas.get
-
Elenca schemi:
pubsub.schemas.list
-
Elenca le revisioni dello schema:
pubsub.schemas.listRevisions
-
Esegui il rollback di uno schema:
pubsub.schemas.rollback
-
Convalida un messaggio:
pubsub.schemas.validate
-
Ottieni il criterio IAM per uno schema:
pubsub.schemas.getIamPolicy
-
Configura il criterio IAM per uno schema:
pubsub.schemas.setIamPolicy
Potresti anche essere in grado di ottenere queste autorizzazioni con i ruoli personalizzati o altri ruoli predefiniti.
Puoi concedere ruoli e autorizzazioni a entità come utenti, gruppi, domini o account di servizio. Puoi creare uno schema in un progetto e collegarlo a un argomento in un altro progetto. Assicurati di disporre delle autorizzazioni necessarie per ogni progetto.
Linee guida per associare uno schema a un argomento
Puoi associare uno schema a un argomento quando crei o modifichi un argomento. Ecco le linee guida per associare uno schema a un argomento:
Puoi associare uno schema a uno o più argomenti.
Dopo aver associato uno schema a un argomento, ogni messaggio che l'argomento riceve dai publisher deve seguire questo schema.
Quando associ uno schema a un argomento, devi specificare anche la codifica dei messaggi da pubblicare come
BINARY
oJSON
. Se utilizzi JSON con uno schema Avro, presta particolare attenzione alle regole di codifica per le unioni.Se uno schema associato a un argomento presenta revisioni, i messaggi devono corrispondere alla codifica ed essere convalidati in base a una revisione nell'intervallo disponibile. Se non vengono convalidati, il messaggio non viene pubblicato.
Le revisioni vengono provate in ordine cronologico inverso basato sul tempo di creazione. Per creare una revisione dello schema, consulta Eseguire il commit di una revisione dello schema.
Logica di convalida per uno schema di messaggi
Quando associ uno schema a un argomento e se lo schema ha revisioni, puoi specificare un intervallo di sottoinsiemi di revisioni da utilizzare. Se non specifichi un intervallo, per la convalida viene utilizzato l'intero intervallo.
Se non specifichi una revisione come Prima revisione consentita, per la convalida viene utilizzata la revisione esistente meno recente dello schema. Se non specifichi una revisione come Ultima revisione consentita, viene utilizzata la revisione esistente più recente dello schema.
Prendiamo come esempio lo schema S
collegato all'argomento T
.
Lo schema S
ha gli ID revisione A
, B
, C
e D
creati in ordine, dove A
è la prima o meno recente. Nessuno schema è identico
o esegue il rollback di uno schema esistente.
Se imposti solo il campo Prima revisione consentita su
B
, i messaggi conformi solo allo schemaA
vengono rifiutati, mentre quelli conformi agli schemiB
,C
eD
vengono accettati.Se imposti solo il campo Ultima revisione consentita su
C
, i messaggi conformi agli schemiA
,B
eC
vengono accettati, mentre quelli conformi solo allo schemaD
vengono rifiutati.Se imposti entrambi i campi Prima revisione consentita su
B
e Ultima revisione consentita suC
, vengono accettati i messaggi conformi agli schemiB
eC
.Puoi anche impostare la prima e l'ultima revisione sullo stesso ID revisione. In questo caso, vengono accettati solo i messaggi conformi a quella revisione.
Creare e associare uno schema durante la creazione di un argomento
Puoi creare un argomento con uno schema utilizzando la console Google Cloud, gcloud CLI, l'API Pub/Sub o le librerie client di Cloud.
Console
Nella console Google Cloud, vai alla pagina Argomenti Pub/Sub.
Fai clic su Crea argomento.
Nel campo ID argomento, inserisci un ID per l'argomento.
Per assegnare un nome a un argomento, consulta le linee guida.
Seleziona la casella Utilizza uno schema.
Mantieni le impostazioni predefinite per i restanti campi.
Puoi creare uno schema o utilizzarne uno esistente.
Se vuoi creare uno schema, segui questi passaggi: `
- In Seleziona uno schema Pub/Sub, scegli Crea un nuovo schema.
La pagina Crea schema viene visualizzata in una scheda secondaria.
Segui i passaggi descritti in Creare uno schema.
Torna alla scheda Crea argomento e fai clic su Aggiorna.
Cerca lo schema nel campo Seleziona uno schema Pub/Sub.
Seleziona la codifica del messaggio come JSON o Binario.
Lo schema appena creato ha un ID revisione. Puoi creare revisioni dello schema aggiuntive come descritto in Eseguire il commit di una revisione dello schema.
Se vuoi associare uno schema già creato, segui questi passaggi:
Per Seleziona uno schema Pub/Sub, scegli uno schema esistente.
Seleziona la codifica del messaggio come JSON o Binario.
(Facoltativo) Se lo schema selezionato presenta revisioni, in Intervallo revisioni utilizza i menu a discesa Prima revisione consentita e Ultima revisione consentita.
Puoi specificare entrambi i campi, specificarne uno solo o mantenere le impostazioni predefinite in base ai tuoi requisiti.
Mantieni le impostazioni predefinite per i restanti campi.
Fai clic su Crea per salvare l'argomento e assegnarlo allo schema selezionato.
gcloud
Per creare un argomento assegnato con uno schema creato in precedenza, esegui il comando gcloud pubsub topics create
:
gcloud pubsub topics create TOPIC_ID \ --message-encoding=ENCODING_TYPE \ --schema=SCHEMA_ID \ --first-revision-id=FIRST_REVISION_ID \ --last-revision-id=LAST_REVISION_ID \
Dove:
- TOPIC_ID è l'ID dell'argomento che stai creando.
- ENCODING_TYPE è la codifica dei messaggi convalidati in base allo schema. Questo valore deve essere impostato su
JSON
oBINARY
. - SCHEMA_ID è l'ID di uno schema esistente.
- FIRST_REVISION_ID è l'ID della revisione meno recente in base alla quale eseguire la convalida.
- LAST_REVISION_ID è l'ID della revisione più recente in base a cui eseguire la convalida.
Sia --first-revision-id
che --last-revision-id
sono facoltativi.
Puoi anche assegnare uno schema da un altro progetto Google Cloud:
gcloud pubsub topics create TOPIC_ID \ --message-encoding=ENCODING_TYPE \ --schema=SCHEMA_ID \ --schema-project=SCHEMA_PROJECT \ --project=TOPIC_PROJECT
Dove:
- SCHEMA_PROJECT è l'ID del progetto Google Cloud per lo schema.
- TOPIC_PROJECT è l'ID del progetto Google Cloud dell'argomento.
REST
Per creare un argomento, utilizza il metodo projects.topics.create
:
Richiesta:
La richiesta deve essere autenticata con un token di accesso nell'intestazione Authorization
. Per ottenere un token di accesso per le Credenziali predefinite dell'applicazione correnti: gcloud auth application-default print-access-token
.
PUT https://pubsub.googleapis.com/v1/projects/PROJECT_ID/topics/TOPIC_ID Authorization: Bearer ACCESS_TOKEN
Corpo della richiesta:
{ "schemaSettings": { "schema": "SCHEMA_NAME", "encoding": "ENCODING_TYPE" "firstRevisionId": "FIRST_REVISION_ID" "lastRevisionId": "LAST_REVISION_ID" } }
Dove:
- PROJECT_ID è l'ID progetto.
- TOPIC_ID è l'ID del tuo argomento.
- SCHEMA_NAME è il nome dello schema in base al quale devono essere convalidati i messaggi pubblicati. Il formato è:
projects/PROJECT_ID/schemas/SCHEMA_ID
. - ENCODING_TYPE è la codifica dei messaggi convalidati in base allo schema. Deve essere impostato su
JSON
oBINARY
. - FIRST_REVISION_ID è l'ID della revisione meno recente in base alla quale eseguire la convalida.
- LAST_REVISION_ID è l'ID della revisione più recente in base a cui eseguire la convalida.
Sia firstRevisionId
che lastRevisionId
sono facoltativi.
Risposta:
{ "name": "projects/PROJECT_ID/topics/TOPIC_ID", "schemaSettings": { "schema": "SCHEMA_NAME", "encoding": "ENCODING_TYPE" "firstRevisionId": "FIRST_REVISION_ID" "lastRevisionId": "LAST_REVISION_ID" } }
Sia firstRevisionId
che lastRevisionId
vengono omessi se non sono forniti
nella richiesta.
C++
Prima di provare questo esempio, segui le istruzioni di configurazione di C++ riportate nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C++ Pub/Sub.
C#
Prima di provare questo esempio, segui le istruzioni di configurazione di C# nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C# di Pub/Sub.
Go
Prima di provare questo esempio, segui le istruzioni di configurazione di Go nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Go Pub/Sub.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione Java in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
PHP
Prima di provare questo esempio, segui le istruzioni di configurazione PHP nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API PHP Pub/Sub.
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Ruby
Prima di provare questo esempio, segui le istruzioni di configurazione di Ruby riportate in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Ruby Pub/Sub.
Modificare uno schema associato a un argomento
Puoi modificare un argomento per collegare uno schema, rimuovere uno schema o aggiornare l'intervallo di revisioni utilizzato per la convalida dei messaggi. In generale, se hai pianificato modifiche per lo schema in uso, puoi eseguire il commit di una nuova revisione e aggiornare l'intervallo di revisioni utilizzate per l'argomento.
Puoi modificare uno schema associato a un argomento utilizzando la console Google Cloud, gcloud CLI, l'API Pub/Sub o le librerie client di Cloud.
Console
Nella console Google Cloud, vai alla pagina Argomenti Pub/Sub.
Fai clic sull'ID argomento di un argomento.
Nella pagina dei dettagli dell'argomento, fai clic su Modifica.
Puoi apportare le seguenti modifiche allo schema.
L'applicazione delle modifiche potrebbe richiedere qualche minuto.
Se vuoi rimuovere lo schema dall'argomento, nella pagina Modifica argomento deseleziona la casella di controllo Usa uno schema.
Se vuoi modificare lo schema, selezionane il nome nella sezione Schema.
Aggiorna gli altri campi come richiesto.
- Se vuoi aggiornare l'intervallo di revisioni, in Intervallo di revisioni utilizza i menu a discesa Prima revisione consentita e Ultima revisione consentita.
Puoi specificare entrambi i campi, specificarne uno solo o mantenere le impostazioni predefinite in base ai tuoi requisiti.
Fai clic su Aggiorna per salvare le modifiche.
gcloud
gcloud pubsub topics update TOPIC_ID \ --message-encoding=ENCODING_TYPE \ --schema=SCHEMA_NAME \ --first-revision-id=FIRST_REVISION_ID \ --last-revision-id=LAST_REVISION_ID \
Dove:
- TOPIC_ID è l'ID dell'argomento che stai creando.
- ENCODING_TYPE è la codifica dei messaggi convalidati in base allo schema. Questo valore deve essere impostato su
JSON
oBINARY
. - SCHEMA_NAME è il nome di uno schema esistente.
- FIRST_REVISION_ID è l'ID della revisione meno recente in base alla quale eseguire la convalida.
- LAST_REVISION_ID è l'ID della revisione più recente in base a cui eseguire la convalida.
Sia --first-revision-id
che --last-revision-id
sono facoltativi.
REST
Per aggiornare un argomento, utilizza il metodo projects.topics.patch
:
Richiesta:
La richiesta deve essere autenticata con un token di accesso nell'intestazione Authorization
. Per ottenere un token di accesso per le Credenziali predefinite dell'applicazione correnti: gcloud auth application-default print-access-token
.
PATCH https://pubsub.googleapis.com/v1/projects/PROJECT_ID/topics/TOPIC_ID Authorization: Bearer ACCESS_TOKEN
Corpo della richiesta:
{ "schemaSettings": { "schema": "SCHEMA_NAME", "encoding": "ENCODING_TYPE" "firstRevisionId": "FIRST_REVISION_ID" "lastRevisionId": "LAST_REVISION_ID" "update_mask": } }
Dove:
- PROJECT_ID è l'ID progetto.
- TOPIC_ID è l'ID del tuo argomento.
- SCHEMA_NAME è il nome dello schema in base al quale devono essere convalidati i messaggi pubblicati. Il formato è:
projects/PROJECT_ID/schemas/SCHEMA_ID
. - ENCODING_TYPE è la codifica dei messaggi convalidati in base allo schema. Deve essere impostato su
JSON
oBINARY
. - FIRST_REVISION_ID è l'ID della revisione meno recente in base alla quale eseguire la convalida.
- LAST_REVISION_ID è l'ID della revisione più recente in base a cui eseguire la convalida.
Sia firstRevisionId
che lastRevisionId
sono facoltativi.
Risposta:
{ "name": "projects/PROJECT_ID/topics/TOPIC_ID", "schemaSettings": { "schema": "SCHEMA_NAME", "encoding": "ENCODING_TYPE" "firstRevisionId": "FIRST_REVISION_ID" "lastRevisionId": "LAST_REVISION_ID" } }
Sia firstRevisionId
che lastRevisionId
non sono impostati dopo l'aggiornamento.
C++
Prima di provare questo esempio, segui le istruzioni di configurazione di C++ riportate nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C++ Pub/Sub.
Go
Prima di provare questo esempio, segui le istruzioni di configurazione di Go nella Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Go Pub/Sub.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione Java in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida sull'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
0Passaggi successivi
- Eseguire il commit di una revisione dello schema
- Pubblicare messaggi in un argomento con uno schema
- Convalidare una definizione di schema
- Convalidare un messaggio per uno schema