schemas

Creates, updates, deletes, gets or lists a schemas resource.

Overview

Name	schemas
Type	Resource
Id	google.pubsub.schemas

Fields

The following fields are returned by SELECT queries:

projects_schemas_get

Name	Datatype	Description
name	string	Required. Name of the schema. Format is projects/{project}/schemas/{schema}.
definition	string	The definition of the schema. This should contain a string representing the full definition of the schema that is a valid schema definition of the type specified in type.
revisionCreateTime	string (google-datetime)	Output only. The timestamp that the revision was created.
revisionId	string	Output only. Immutable. The revision ID of the schema.
type	string	The type of the schema definition. (TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO)

projects_schemas_list

Name	Datatype	Description
name	string	Required. Name of the schema. Format is projects/{project}/schemas/{schema}.
definition	string	The definition of the schema. This should contain a string representing the full definition of the schema that is a valid schema definition of the type specified in type.
revisionCreateTime	string (google-datetime)	Output only. The timestamp that the revision was created.
revisionId	string	Output only. Immutable. The revision ID of the schema.
type	string	The type of the schema definition. (TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO)

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
projects_schemas_get	select	projectsId, schemasId	view	Gets a schema.
projects_schemas_list	select	projectsId	pageSize, view, pageToken	Lists schemas in a project.
projects_schemas_create	insert	projectsId	schemaId	Creates a schema.
projects_schemas_delete	delete	projectsId, schemasId		Deletes a schema.
projects_schemas_validate	exec	projectsId		Validates a schema.
projects_schemas_validate_message	exec	projectsId		Validates a message against a schema.
projects_schemas_rollback	exec	projectsId, schemasId		Creates a new schema revision that is a copy of the provided revision_id.
projects_schemas_commit	exec	projectsId, schemasId		Commits a new schema revision to an existing schema.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
projectsId	string
schemasId	string
pageSize	integer (int32)
pageToken	string
schemaId	string
view	string

SELECT examples

projects_schemas_get

Gets a schema.

SELECT
name,
definition,
revisionCreateTime,
revisionId,
type
FROM google.pubsub.schemas
WHERE projectsId = '{{ projectsId }}' -- required
AND schemasId = '{{ schemasId }}' -- required
AND view = '{{ view }}'
;

projects_schemas_list

Lists schemas in a project.

SELECT
name,
definition,
revisionCreateTime,
revisionId,
type
FROM google.pubsub.schemas
WHERE projectsId = '{{ projectsId }}' -- required
AND pageSize = '{{ pageSize }}'
AND view = '{{ view }}'
AND pageToken = '{{ pageToken }}'
;

INSERT examples

projects_schemas_create

Creates a schema.

INSERT INTO google.pubsub.schemas (
data__definition,
data__name,
data__type,
projectsId,
schemaId
)
SELECT 
'{{ definition }}',
'{{ name }}',
'{{ type }}',
'{{ projectsId }}',
'{{ schemaId }}'
RETURNING
name,
definition,
revisionCreateTime,
revisionId,
type
;

Manifest

# Description fields are for documentation purposes
- name: schemas
props:
  - name: projectsId
    value: "{{ projectsId }}"
    description: Required parameter for the schemas resource.
  - name: definition
    value: "{{ definition }}"
    description: |
      The definition of the schema. This should contain a string representing the full definition of the schema that is a valid schema definition of the type specified in `type`.
  - name: name
    value: "{{ name }}"
    description: |
      Required. Name of the schema. Format is `projects/{project}/schemas/{schema}`.
  - name: type
    value: "{{ type }}"
    description: |
      The type of the schema definition.
    valid_values: ['TYPE_UNSPECIFIED', 'PROTOCOL_BUFFER', 'AVRO']
  - name: schemaId
    value: "{{ schemaId }}"

DELETE examples

projects_schemas_delete

Deletes a schema.

DELETE FROM google.pubsub.schemas
WHERE projectsId = '{{ projectsId }}' --required
AND schemasId = '{{ schemasId }}' --required
;

Lifecycle Methods

projects_schemas_validate

Validates a schema.

EXEC google.pubsub.schemas.projects_schemas_validate 
@projectsId='{{ projectsId }}' --required 
@@json=
'{
"schema": "{{ schema }}"
}'
;

projects_schemas_validate_message

Validates a message against a schema.

EXEC google.pubsub.schemas.projects_schemas_validate_message 
@projectsId='{{ projectsId }}' --required 
@@json=
'{
"message": "{{ message }}", 
"encoding": "{{ encoding }}", 
"name": "{{ name }}", 
"schema": "{{ schema }}"
}'
;

projects_schemas_rollback

Creates a new schema revision that is a copy of the provided revision_id.

EXEC google.pubsub.schemas.projects_schemas_rollback 
@projectsId='{{ projectsId }}' --required, 
@schemasId='{{ schemasId }}' --required 
@@json=
'{
"revisionId": "{{ revisionId }}"
}'
;

projects_schemas_commit

Commits a new schema revision to an existing schema.

EXEC google.pubsub.schemas.projects_schemas_commit 
@projectsId='{{ projectsId }}' --required, 
@schemasId='{{ schemasId }}' --required 
@@json=
'{
"schema": "{{ schema }}"
}'
;