Questo documento mostra come eseguire il commit di una revisione dello schema e gli argomenti Pub/Sub.
Prima di iniziare
- Scopri come funzionano gli schemi Pub/Sub.
- Crea uno schema.
Ruoli e autorizzazioni richiesti
Per ottenere le autorizzazioni necessarie per eseguire il commit di una revisione dello schema e gestire gli schemi,
chiedi all'amministratore di concederti
Ruolo IAM dell'editor Pub/Sub (roles/pubsub.editor
) nel progetto.
Per saperne di più sulla concessione dei ruoli, consulta Gestire l'accesso.
Questo ruolo predefinito contiene le autorizzazioni necessarie per eseguire il commit di una revisione dello schema e gestire gli schemi. Per vedere le autorizzazioni esatte obbligatorie, espandi la sezione Autorizzazioni obbligatorie:
Autorizzazioni obbligatorie
Per eseguire il commit di una revisione dello schema e gestire gli schemi sono necessarie le seguenti autorizzazioni:
-
Crea schema:
pubsub.schemas.create
-
Associa schema all'argomento:
pubsub.schemas.attach
-
Esegui il commit di una revisione dello schema:
pubsub.schemas.commit
-
Elimina uno schema o una revisione dello schema:
pubsub.schemas.delete
-
Ottieni uno schema o una revisione dello schema:
pubsub.schemas.get
-
Elenca gli 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 riuscire a ottenere queste autorizzazioni con ruoli personalizzati 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 a un argomento di un altro progetto. Assicurati di disporre delle autorizzazioni necessarie per per ogni progetto.
Rivedi uno schema
Puoi eseguire il commit di una revisione dello schema utilizzando console Google Cloud, gcloud CLI, l'API Pub/Sub o le librerie client di Cloud.
Di seguito sono riportate alcune linee guida per eseguire il commit di una revisione dello schema:
Puoi rivedere uno schema rispettando vincoli specifici:
Per gli schemi del buffer di protocollo, puoi aggiungere o rimuovere campi facoltativi. Non puoi aggiungere o eliminare altri campi. Inoltre, non puoi modificare campo esistente.
Per gli schemi Avro, consulta Documentazione Avro per le regole sulla risoluzione dello schema. Una nuova revisione deve seguire le regole sia che si tratti dello schema Reader che dello schema writer.
Uno schema può avere un massimo di 20 revisioni alla volta. Se superi il limite, elimina una revisione dello schema prima di crearne un'altra.
A ogni revisione è associato un ID revisione univoco. ID revisione è un UUID di otto caratteri generato automaticamente.
Quando aggiorni l'intervallo di revisioni o la revisione di uno schema utilizzato dell'argomento, potrebbero essere necessari alcuni minuti prima che le modifiche abbiano effetto.
Console
Per creare una revisione dello schema:
Nella console Google Cloud, vai alla pagina Schemi Pub/Sub.
Fai clic sull'ID schema di uno schema esistente.
Si apre la pagina Dettagli schema relativa allo schema.
Fai clic su Crea revisione.
Viene visualizzata la pagina Crea revisione schema.
Apporta le modifiche necessarie.
Ad esempio, per lo schema di esempio in Avro che hai creato in Crea uno schema, puoi aggiungere un ulteriore attributo facoltativo denominato
Price
, nel seguente modo:{ "type": "record", "name": "Avro", "fields": [ { "name": "ProductName", "type": "string", "default": "" }, { "name": "SKU", "type": "int", "default": 0 }, { "name": "InStock", "type": "boolean", "default": false }, { "name": "Price", "type": "double", "default": "0.0" } ] }
Fai clic su Convalida definizione per verificare se la definizione dello schema è corretta.
Puoi anche convalidare i messaggi per lo schema.
Fai clic su Verifica messaggio per provare un messaggio di esempio.
Nella finestra Messaggio di prova, seleziona un tipo di Codifica del messaggio.
Nel corpo del messaggio, inserisci un messaggio di prova.
Ad esempio, ecco un messaggio di esempio per lo schema di test. In questo esempio, seleziona Codifica del messaggio come
JSON
.{"ProductName":"GreenOnions", "SKU":34543, "Price":12, "InStock":true}
Fai clic su Test.
Fai clic su Esegui il commit per salvare lo schema.
gcloud
gcloud pubsub schemas commit SCHEMA_ID \ --type=SCHEMA_TYPE \ --definition=SCHEMA_DEFINITION
Dove:
- SCHEMA_TYPE è
avro
oprotocol-buffer
. - SCHEMA_DEFINITION è un
string
contenente la definizione di lo schema, formattato in base al tipo di schema scelto.
Puoi anche specificare la definizione dello schema nel file:
gcloud pubsub schemas commit SCHEMA_ID \ --type=SCHEMA_TYPE \ --definition-file=SCHEMA_DEFINITION_FILE
Dove:
- SCHEMA_TYPE è
avro
oprotocol-buffer
. - SCHEMA_DEFINITION_FILE è un
string
contenente il percorso alla file con la definizione dello schema, formattato in base allo schema scelto tipo di schema.
REST
Per eseguire il commit di una revisione dello schema, invia una richiesta POST come la seguente:
POST https://pubsub.googleapis.com/v1/projects/PROJECT_ID/schemas/SCHEMA_ID:commit Authorization: Bearer $(gcloud auth application-default print-access-token) Content-Type: application/json --data @response-body.json
Specifica i seguenti campi nel corpo della richiesta:
{ "definition": SCHEMA_DEFINITION "type": SCHEMA_TYPE "name": SCHEMA_NAME }
Dove:
- SCHEMA_TYPE è
AVRO
oPROTOCOL_BUFFER
. - SCHEMA_DEFINITION è una stringa contenente la definizione di lo schema, formattato in base al tipo di schema scelto.
- SCHEMA_NAME è il nome di uno schema esistente.
Il corpo della risposta deve contenere una rappresentazione JSON di un risorsa schema. Ad esempio:
{ "name": SCHEMA_NAME, "type": SCHEMA_TYPE, "definition": SCHEMA_DEFINITION "revisionId": REVISION_ID "revisionCreateTime": REVISION_CREATE_TIME }
Dove:
- REVISION_ID è l'ID generato dal server per la revisione.
- REVISION_CREATE_TIME è il timestamp ISO 8601 in cui revisione è stata creata.
Vai
Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.
Avro
Proto
C++
Prima di provare questo esempio, segui le istruzioni per la configurazione di C++ in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.
Avro
Proto
Java
Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Avro
Proto
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Avro
Proto
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Avro
Proto
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida all'utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Avro
Proto
Dopo aver eseguito il commit di una revisione dello schema, puoi vedere i dettagli della nuova revisione alla pagina Schemi.
Passaggi successivi
- Eliminare una revisione dello schema
- Elenco delle revisioni di uno schema
- Eseguire il rollback di una revisione dello schema