Crea suscripciones a BigQuery

En este documento, se describe cómo crear una suscripción a BigQuery. Puedes usar la consola de Google Cloud, Google Cloud CLI, la biblioteca cliente, o la API de Pub/Sub para crear una suscripción a BigQuery.

Antes de comenzar

Antes de leer este documento, asegúrate de estar familiarizado con la siguiente información:

Además de tu familiaridad con Pub/Sub y BigQuery, asegúrate de cumplir con los siguientes requisitos antes de crear una suscripción a BigQuery:

  • Existe una tabla de BigQuery. Como alternativa, puedes crear una cuando creas la suscripción a BigQuery, como se describe en en las secciones posteriores de este documento.

  • La compatibilidad entre el esquema del tema de Pub/Sub y la tabla de BigQuery. Si agregas un panel de control de BigQuery, obtendrás un error relacionado con la compatibilidad mensaje. Para obtener más información, consulta Compatibilidad con el esquema.

Funciones y permisos requeridos

La siguiente es una lista de lineamientos relacionados con los roles y los permisos:

  • Para crear una suscripción, debes configurar el control de acceso en el proyecto a nivel de organización.

  • También necesitas permisos a nivel de recursos si tu las suscripciones y los temas están en proyectos diferentes, como se explica más adelante en esta sección.

  • Para crear una suscripción a BigQuery, el La cuenta de servicio de Pub/Sub debe tener permiso para escribir en el en una tabla específica de BigQuery. Para obtener más información otorgar estos permisos, consulta la siguiente sección de este documento.

  • Puedes configurar una suscripción a BigQuery en un proyecto para escribir en una tabla de BigQuery en un proyecto diferente.

A fin de obtener los permisos que necesitas para crear suscripciones a BigQuery, solicita a tu administrador que te otorgue el Rol de IAM de Editor de Pub/Sub (roles/pubsub.editor) en el proyecto. Para obtener más información sobre cómo otorgar roles, consulta Administra el acceso.

Este rol predefinido contiene los permisos necesarios para crear suscripciones a BigQuery. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:

Permisos necesarios

Se requieren los siguientes permisos para crear suscripciones a BigQuery:

  • Extraer de una suscripción: pubsub.subscriptions.consume
  • Crea una suscripción: pubsub.subscriptions.create
  • Borra una suscripción: pubsub.subscriptions.delete
  • Obtén una suscripción: pubsub.subscriptions.get
  • Muestra una suscripción: pubsub.subscriptions.list
  • Actualiza una suscripción: pubsub.subscriptions.update
  • Adjunta una suscripción a un tema: pubsub.topics.attachSubscription
  • Obtén la política de IAM para una suscripción: pubsub.subscriptions.getIamPolicy
  • Configura la política de IAM para una suscripción: pubsub.subscriptions.setIamPolicy

También puedes obtener estos permisos con roles personalizados o con otros roles predefinidos

Si necesitas crear BigQuery suscripciones en un proyecto que están asociadas con un tema de otro solicita a tu administrador de temas que también te otorgue el Editor de Pub/Sub (roles/pubsub.editor) rol de IAM en el tema.

Asigna roles de BigQuery a la cuenta de servicio de Pub/Sub

Algunos servicios de Google Cloud tienen cuentas de servicio administradas por Google Cloud que permiten a las servicios accedan a tus recursos. Estas cuentas de servicio son conocidos como agentes de servicio. Pub/Sub crea y mantiene un cuenta de servicio para cada proyecto en el formato service-project-number@gcp-sa-pubsub.iam.gserviceaccount.com.

Para crear una suscripción a BigQuery, el directorio de Pub/Sub la cuenta de servicio debe tener permiso para escribir a la tabla específica de BigQuery y leer los metadatos de la tabla.

Otorgar al editor de datos de BigQuery (roles/bigquery.dataEditor) a la cuenta de servicio de Pub/Sub.

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

    Ir a IAM

  2. Haz clic en Otorgar acceso.

  3. En la sección Agregar principales, ingresa el nombre de tu Pub/Sub. cuenta de servicio. El formato de la cuenta de servicio es service-project-number@gcp-sa-pubsub.iam.gserviceaccount.com. Por ejemplo, para un proyecto con project-number=112233445566, la cuenta de servicio tiene el formato service-112233445566@gcp-sa-pubsub.iam.gserviceaccount.com.

  4. En la sección Asignar roles, haz clic en Agregar otro rol.

  5. En el menú desplegable Seleccionar un rol, ingresa BigQuery. y selecciona el rol de editor de datos de BigQuery.

  6. Haz clic en Guardar.

Para obtener más información sobre IAM de BigQuery, consulta Roles y permisos de BigQuery.

Propiedades de suscripción a BigQuery

Cuando configuras una suscripción a BigQuery, puedes especificar los siguientes elementos: propiedades.

Propiedades comunes

Obtén más información sobre las propiedades de suscripción comunes que puedes configurar en todas las suscripciones.

Usar el esquema de tema

Esta opción permite que Pub/Sub use el esquema del tema de Pub/Sub al que suscripción está adjunta. Además, Pub/Sub escribe los campos de los mensajes en las direcciones columnas en la tabla de BigQuery.

Cuando uses esta opción, recuerda verificar los siguientes requisitos adicionales:

  • Los campos en el esquema del tema y el esquema de BigQuery deben tener los mismos nombres y sus tipos deben ser compatibles entre sí.

  • Cualquier campo opcional en el esquema del tema también debe estar opcional en el esquema de BigQuery.

  • No es necesario que los campos obligatorios del esquema de tema necesarios en el esquema de BigQuery.

  • Si hay campos de BigQuery que no están presentes en el esquema del tema, estos campos de BigQuery debe estar en el modo NULLABLE.

  • Si el esquema de tema tiene campos adicionales no están presentes en el esquema de BigQuery se pueden descartar, selecciona la opción Descartar campos desconocidos.

  • Puedes seleccionar solo una de las propiedades de suscripción, Usar el esquema de tema. o Usar un esquema de tabla.

Si no seleccionas las opciones Use topic schema o Use table schema, asegúrate de que la tabla de BigQuery tenga una columna llamada data de escribe BYTES, STRING o JSON. Pub/Sub escribe el mensaje en esta columna de BigQuery.

Es posible que no veas cambios en el esquema de temas de Pub/Sub o El esquema de la tabla de BigQuery se aplica de inmediato con mensajes se escribe en la tabla de BigQuery. Por ejemplo, si la columna Drop campo desconocidos está habilitada y hay un campo presente en la el esquema de Pub/Sub, pero no el esquema de BigQuery, mensajes escritos en la tabla de BigQuery podrían no contener el campo después de agregarlo al esquema de BigQuery. Con el tiempo, se sincronizan los esquemas y los mensajes posteriores incluyen el campo.

Cuando usas la opción Usar el esquema de tema de BigQuery puedes aprovechar los cambios de BigQuery la captura de datos (CDC). La CDC actualiza tus tablas de BigQuery procesar y aplicar cambios a las filas existentes.

Si deseas obtener más información sobre esta función, consulta Cómo transmitir actualizaciones de tablas con la captura de datos modificados.

Para aprender a usar esta función con suscripciones a BigQuery, consulta Captura de datos modificados de BigQuery.

Usar el esquema de tabla

Esta opción permite que Pub/Sub use el esquema de la tabla de BigQuery para escribir los campos de un JSON mensaje a las columnas correspondientes. Cuando uses esta opción, recuerda consulta los siguientes requisitos adicionales:

  • Los mensajes publicados deben estar en formato JSON.

  • Si el tema de la suscripción tiene un esquema asociado y, luego, la propiedad de codificación de mensajes debe establecerse en JSON.

  • Si hay campos de BigQuery que no están presentes en los mensajes, estos campos de BigQuery deben estar en modo NULLABLE.

  • Si los mensajes tienen campos adicionales que no están presentes en el el esquema de BigQuery y estos campos se pueden descartar, la opción Descartar campos desconocidos.

  • En el mensaje JSON, los valores DATE, DATETIME, TIME y TIMESTAMP deben ser números enteros que cumplan con las representaciones admitidas.

  • En el mensaje JSON, los valores NUMERIC y BIGNUMERIC deben ser bytes codificados con el BigDecimalByteStringEncoder.

  • Puedes seleccionar solo una de las propiedades de suscripción, Usar el esquema de tema. o Usar un esquema de tabla.

Si no seleccionas las opciones Use topic schema o Use table schema, asegúrate de que la tabla de BigQuery tenga una columna llamada data de escribe BYTES, STRING o JSON. Pub/Sub escribe el mensaje en esta columna de BigQuery.

Es posible que no veas los cambios en el esquema de la tabla de BigQuery efecto de inmediato con mensajes escritos en la tabla de BigQuery. Por ejemplo, si la opción Descartar campos desconocidos está habilitada y un campo está presentes en los mensajes, pero no en el esquema de BigQuery, mensajes escritos en la tabla de BigQuery podrían no contener el campo después de agregarlo al esquema de BigQuery. Con el tiempo, las sincronizaciones de esquema y los mensajes posteriores incluyen el campo.

Cuando usas la opción Usar el esquema de tabla para tu suscripción a BigQuery, también puede aprovechar la captura de datos modificados (CDC) de BigQuery. La CDC actualiza las tablas de BigQuery procesando y aplicando los cambios en las tablas existentes filas.

Si deseas obtener más información sobre esta función, consulta Cómo transmitir actualizaciones de tablas con la captura de datos modificados.

Para obtener información sobre cómo utilizar esta función con suscripciones a BigQuery, consulta Captura de datos modificados de BigQuery.

Quitar campos desconocidos

Esta opción se utiliza con las opciones Usar esquema de tema o Usar esquema de tabla de 12 a 1 con la nueva opción de compresión. Esta opción permite que Pub/Sub descarte cualquier campo que esté presente en el tema. pero no en el de BigQuery. Sin Drop desconocida campos configurados, los mensajes con campos adicionales no se escriben en BigQuery y permanecen en las tareas pendientes de la suscripción. El suscripción termina en un estado de error.

Escribir metadatos

Esta opción permite que Pub/Sub escribir los metadatos de cada mensaje en columnas adicionales del en la tabla de BigQuery. De lo contrario, los metadatos no se escribe en la tabla de BigQuery.

Si seleccionas la opción Escribir metadatos, asegúrate de que el La tabla de BigQuery tiene los campos que se describen en la siguiente tabla.

Si no seleccionas la opción Escribir metadatos, la tabla de BigQuery de destino solo requiere el campo data, a menos que use_topic_schema es verdadero. Si seleccionas Escribir metadatos y Usa las opciones de esquema de tema, luego, el esquema del tema debe No contienen ningún campo con nombres que coincidan con los de los parámetros de metadatos. Esta limitación incluye versiones en mayúsculas y minúsculas de estos parámetros de Snake case.

Parámetros
subscription_name

STRING

Es el nombre de una suscripción.
message_id

STRING

ID de un mensaje
publish_time

TIMESTAMP

Indica la hora de publicación de un mensaje.
data

BYTES, STRING o JSON

El cuerpo del mensaje.

El campo data es obligatorio para todos los destinos las tablas de BigQuery que no seleccionan Usar el esquema de tema o Usar el esquema de tabla. Si el botón es de tipo JSON, el cuerpo del mensaje debe ser JSON válido.
attributes

STRING o JSON

Un objeto JSON que contiene todos los atributos del mensaje. También contiene campos adicionales que forman parte del Un mensaje de Pub/Sub que incluye la clave de ordenamiento, si están presentes.

Crea una suscripción a BigQuery

En los siguientes ejemplos, se muestra cómo crear una suscripción con la entrega de BigQuery.

Console

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

    Ir a Suscripciones

  2. Haz clic en Crear suscripción.
  3. En el campo ID de la suscripción, ingresa un nombre.

    Para información sobre cómo asignar un nombre a una suscripción, consulta Lineamientos para asignar un nombre un tema o una suscripción.

  4. Elige o crea un tema desde el menú desplegable. La suscripción recibe mensajes del tema.
  5. Selecciona Tipo de entrega como Escribir en BigQuery
  6. Selecciona el proyecto para la tabla de BigQuery.
  7. Selecciona un conjunto de datos existente o crea uno nuevo.

    Información para crear un conjunto de datos, consulta Cómo crear conjuntos de datos.

  8. Selecciona una tabla existente o crea una nueva.

    Para obtener información sobre cómo crear una tabla, consulta Crea tablas.

  9. Te recomendamos que habilites la opción Dead el uso de letras para manejar las fallas de los mensajes.

    Para obtener más información, consulta Dead de la carta.

  10. Haz clic en Crear.

También puedes crear una suscripción desde la página Temas. Este acceso directo es útil para asociar temas a suscripciones.

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

    Ir a Temas

  2. Haz clic en la junto al tema que quieras revisar. para crear una suscripción.
  3. En el menú contextual, selecciona Crear suscripción (Create subscription).
  4. Selecciona Tipo de entrega como Escribir en BigQuery
  5. Selecciona el proyecto para la tabla de BigQuery.
  6. Selecciona un conjunto de datos existente o crea uno nuevo.

    Información para crear un conjunto de datos, consulta Cómo crear conjuntos de datos.

  7. Selecciona una tabla existente o crea una nueva.

    Para obtener información sobre cómo crear un conjunto de datos, consulta Crea tablas.

  8. Te recomendamos que habilites la opción Dead el uso de letras para manejar las fallas de los mensajes.

    Para obtener más información, consulta Dead de la carta.

  9. Haz clic en Crear.

gcloud

  1. En la consola de Google Cloud, activa Cloud Shell.

    Activar Cloud Shell

    En la parte inferior de la consola de Google Cloud, se inicia una sesión de Cloud Shell en la que se muestra una ventana de línea de comandos. Cloud Shell es un entorno de shell con Google Cloud CLI ya instalada y con valores ya establecidos para el proyecto actual. La sesión puede tardar unos segundos en inicializarse.

  2. Para crear una suscripción de Pub/Sub, usa gcloud pubsub subscriptions create. :

    gcloud pubsub subscriptions create SUBSCRIPTION_ID \
    --topic=TOPIC_ID \
    --bigquery-table=PROJECT_ID:DATASET_ID.TABLE_ID

    Reemplaza lo siguiente:

    • SUBSCRIPTION_ID: Especifica el ID del suscripción.
    • TOPIC_ID: Especifica el ID del tema. El este tema requiere un esquema.
    • PROJECT_ID: Especifica el ID del proyecto.
    • DATASET_ID: Especifica el ID de un de tu conjunto de datos. Para crear un conjunto de datos, consulta Crear conjuntos de datos.
    • TABLE_ID: Especifica el ID de una tabla existente. La tabla requiere un campo data si tu tema no tiene un esquema. Para crear una tabla, consulta Crear una tabla vacía con una definición de esquema.

C++

Antes de probar esta muestra, sigue las instrucciones de configuración de C++ que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de C++ de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

namespace pubsub = ::google::cloud::pubsub;
namespace pubsub_admin = ::google::cloud::pubsub_admin;
[](pubsub_admin::SubscriptionAdminClient client,
   std::string const& project_id, std::string const& topic_id,
   std::string const& subscription_id, std::string const& table_id) {
  google::pubsub::v1::Subscription request;
  request.set_name(
      pubsub::Subscription(project_id, subscription_id).FullName());
  request.set_topic(pubsub::Topic(project_id, topic_id).FullName());
  request.mutable_bigquery_config()->set_table(table_id);
  auto sub = client.CreateSubscription(request);
  if (!sub) {
    if (sub.status().code() == google::cloud::StatusCode::kAlreadyExists) {
      std::cout << "The subscription already exists\n";
      return;
    }
    throw std::move(sub).status();
  }

  std::cout << "The subscription was successfully created: "
            << sub->DebugString() << "\n";
}

C#

Antes de probar esta muestra, sigue las instrucciones de configuración de C# que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de C# de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 


using Google.Cloud.PubSub.V1;

public class CreateBigQuerySubscriptionSample
{
    public Subscription CreateBigQuerySubscription(string projectId, string topicId, string subscriptionId, string bigqueryTableId)
    {
        SubscriberServiceApiClient subscriber = SubscriberServiceApiClient.Create();
        TopicName topicName = TopicName.FromProjectTopic(projectId, topicId);
        SubscriptionName subscriptionName = SubscriptionName.FromProjectSubscription(projectId, subscriptionId);

        var subscriptionRequest = new Subscription
        {
            SubscriptionName = subscriptionName,
            TopicAsTopicName = topicName,
            BigqueryConfig = new BigQueryConfig
            {
                Table = bigqueryTableId
            }
        };
        var subscription = subscriber.CreateSubscription(subscriptionRequest);
        return subscription;
    }
}

Go

Antes de probar esta muestra, sigue las instrucciones de configuración de Go que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de Go de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/pubsub"
)

// createBigQuerySubscription creates a Pub/Sub subscription that exports messages to BigQuery.
func createBigQuerySubscription(w io.Writer, projectID, subID string, topic *pubsub.Topic, table string) error {
	// projectID := "my-project-id"
	// subID := "my-sub"
	// topic of type https://godoc.org/cloud.google.com/go/pubsub#Topic
	// table := "my-project-id.dataset_id.table_id"
	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, projectID)
	if err != nil {
		return fmt.Errorf("pubsub.NewClient: %w", err)
	}
	defer client.Close()

	sub, err := client.CreateSubscription(ctx, subID, pubsub.SubscriptionConfig{
		Topic: topic,
		BigQueryConfig: pubsub.BigQueryConfig{
			Table:         table,
			WriteMetadata: true,
		},
	})
	if err != nil {
		return fmt.Errorf("client.CreateSubscription: %w", err)
	}
	fmt.Fprintf(w, "Created BigQuery subscription: %v\n", sub)

	return nil
}

Java

Antes de probar esta muestra, sigue las instrucciones de configuración de Java que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de Java de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
import com.google.pubsub.v1.BigQueryConfig;
import com.google.pubsub.v1.ProjectSubscriptionName;
import com.google.pubsub.v1.ProjectTopicName;
import com.google.pubsub.v1.Subscription;
import java.io.IOException;

public class CreateBigQuerySubscriptionExample {
  public static void main(String... args) throws Exception {
    // TODO(developer): Replace these variables before running the sample.
    String projectId = "your-project-id";
    String topicId = "your-topic-id";
    String subscriptionId = "your-subscription-id";
    String bigqueryTableId = "your-project.your-dataset.your-table";

    createBigQuerySubscription(projectId, topicId, subscriptionId, bigqueryTableId);
  }

  public static void createBigQuerySubscription(
      String projectId, String topicId, String subscriptionId, String bigqueryTableId)
      throws IOException {
    try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {

      ProjectTopicName topicName = ProjectTopicName.of(projectId, topicId);
      ProjectSubscriptionName subscriptionName =
          ProjectSubscriptionName.of(projectId, subscriptionId);

      BigQueryConfig bigqueryConfig =
          BigQueryConfig.newBuilder().setTable(bigqueryTableId).setWriteMetadata(true).build();

      Subscription subscription =
          subscriptionAdminClient.createSubscription(
              Subscription.newBuilder()
                  .setName(subscriptionName.toString())
                  .setTopic(topicName.toString())
                  .setBigqueryConfig(bigqueryConfig)
                  .build());

      System.out.println("Created a BigQuery subscription: " + subscription.getAllFields());
    }
  }
}

Node.js

/**
 * TODO(developer): Uncomment these variables before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';
// const subscriptionNameOrId = 'YOUR_SUBSCRIPTION_NAME_OR_ID';
// const bigqueryTableId = 'YOUR_TABLE_ID';

// Imports the Google Cloud client library
const {PubSub} = require('@google-cloud/pubsub');

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createBigQuerySubscription(
  topicNameOrId,
  subscriptionNameOrId,
  bigqueryTableId
) {
  const options = {
    bigqueryConfig: {
      table: bigqueryTableId,
      writeMetadata: true,
    },
  };

  await pubSubClient
    .topic(topicNameOrId)
    .createSubscription(subscriptionNameOrId, options);

  console.log(`Subscription ${subscriptionNameOrId} created.`);
}

Node.js

/**
 * TODO(developer): Uncomment these variables before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';
// const subscriptionNameOrId = 'YOUR_SUBSCRIPTION_NAME_OR_ID';
// const bigqueryTableId = 'YOUR_TABLE_ID';

// Imports the Google Cloud client library
import {PubSub, CreateSubscriptionOptions} from '@google-cloud/pubsub';

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createBigQuerySubscription(
  topicNameOrId: string,
  subscriptionNameOrId: string,
  bigqueryTableId: string
) {
  const options: CreateSubscriptionOptions = {
    bigqueryConfig: {
      table: bigqueryTableId,
      writeMetadata: true,
    },
  };

  await pubSubClient
    .topic(topicNameOrId)
    .createSubscription(subscriptionNameOrId, options);

  console.log(`Subscription ${subscriptionNameOrId} created.`);
}

PHP

Antes de probar esta muestra, sigue las instrucciones de configuración de PHP que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de PHP de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

use Google\Cloud\PubSub\PubSubClient;
use Google\Cloud\PubSub\V1\BigQueryConfig;

/**
 * Creates a Pub/Sub BigQuery subscription.
 *
 * @param string $projectId  The Google project ID.
 * @param string $topicName  The Pub/Sub topic name.
 * @param string $subscriptionName  The Pub/Sub subscription name.
 * @param string $table      The BigQuery table to which to write.
 */
function create_bigquery_subscription($projectId, $topicName, $subscriptionName, $table)
{
    $pubsub = new PubSubClient([
        'projectId' => $projectId,
    ]);
    $topic = $pubsub->topic($topicName);
    $subscription = $topic->subscription($subscriptionName);
    $config = new BigQueryConfig(['table' => $table]);
    $subscription->create([
        'bigqueryConfig' => $config
    ]);

    printf('Subscription created: %s' . PHP_EOL, $subscription->name());
}

Python

Antes de probar esta muestra, sigue las instrucciones de configuración de Python que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de Python de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

from google.cloud import pubsub_v1

# TODO(developer)
# project_id = "your-project-id"
# topic_id = "your-topic-id"
# subscription_id = "your-subscription-id"
# bigquery_table_id = "your-project.your-dataset.your-table"

publisher = pubsub_v1.PublisherClient()
subscriber = pubsub_v1.SubscriberClient()
topic_path = publisher.topic_path(project_id, topic_id)
subscription_path = subscriber.subscription_path(project_id, subscription_id)

bigquery_config = pubsub_v1.types.BigQueryConfig(
    table=bigquery_table_id, write_metadata=True
)

# Wrap the subscriber in a 'with' block to automatically call close() to
# close the underlying gRPC channel when done.
with subscriber:
    subscription = subscriber.create_subscription(
        request={
            "name": subscription_path,
            "topic": topic_path,
            "bigquery_config": bigquery_config,
        }
    )

print(f"BigQuery subscription created: {subscription}.")
print(f"Table for subscription is: {bigquery_table_id}")

Ruby

Antes de probar esta muestra, sigue las instrucciones de configuración de Ruby que se encuentran en el Guía de inicio rápido de Pub/Sub con bibliotecas cliente. Para obtener más información, consulta la API de Ruby de Pub/Sub documentación de referencia.

Para autenticarte en Pub/Sub, configura las credenciales predeterminadas de la aplicación. Si deseas obtener más información, consulta Configura la autenticación para bibliotecas cliente. 

require "google/cloud/pubsub"

##
# Shows how to create a BigQuery subscription where messages published
# to a topic populates a BigQuery table.
#
# @param project_id [String]
# Your Google Cloud project (e.g. "my-project")
# @param topic_id [String]
# Your topic name (e.g. "my-secret")
# @param subscription_id [String]
# ID for new subscription to be created (e.g. "my-subscription")
# @param bigquery_table_id [String]
# ID of bigquery table (e.g "my-project:dataset-id.table-id")
#
def pubsub_create_bigquery_subscription project_id:, topic_id:, subscription_id:, bigquery_table_id:
  pubsub = Google::Cloud::Pubsub.new project_id: project_id
  topic = pubsub.topic topic_id
  subscription = topic.subscribe subscription_id,
                                 bigquery_config: {
                                   table: bigquery_table_id,
                                   write_metadata: true
                                 }
  puts "BigQuery subscription created: #{subscription_id}."
  puts "Table for subscription is: #{bigquery_table_id}"
end

¿Qué sigue?