crea sottoscrizioni Cloud Storage

Questo documento descrive come creare un abbonamento a Cloud Storage. Puoi utilizzare la console Google Cloud, Google Cloud CLI, la libreria client oppure l'API Pub/Sub per creare un abbonamento a Cloud Storage.

Prima di iniziare

Prima di leggere questo documento, assicurati di conoscere quanto segue:

• Come funziona un abbonamento a Cloud Storage.
• Come funziona Cloud Storage e come creare e gestire i bucket Cloud Storage.
• Come configurare un argomento messaggi non recapitabili per gestire gli errori relativi ai messaggi.

Ruoli e autorizzazioni richiesti

Di seguito è riportato un elenco di linee guida relative a ruoli e autorizzazioni:

• Per creare una sottoscrizione, devi configurare il controllo dell'accesso a livello di progetto livello.

• Sono inoltre necessarie autorizzazioni a livello di risorsa se le iscrizioni e gli argomenti si trovano in progetti diversi, come spiegato più avanti in questa sezione.

• Per creare una sottoscrizione Cloud Storage, L'account di servizio Pub/Sub deve disporre dell'autorizzazione per scrivere un bucket Cloud Storage specifico e leggere i metadati del bucket. Per ulteriori informazioni su come concedere queste autorizzazioni, consulta la sezione successiva di questo documento.

Per ottenere le autorizzazioni necessarie per creare sottoscrizioni Cloud Storage, chiedi all'amministratore di concederti il ruolo IAM Editor Pub/Sub (roles/pubsub.editor) nel progetto. Per saperne di più sulla concessione dei ruoli, consulta Gestire l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per creare abbonamenti Cloud Storage. Per vedere le autorizzazioni esatte obbligatorie, espandi la sezione Autorizzazioni obbligatorie:

Autorizzazioni obbligatorie

Per creare sottoscrizioni Cloud Storage sono necessarie le seguenti autorizzazioni:

• Creare un abbonamento: pubsub.subscriptions.create
• Allega una sottoscrizione a un argomento: pubsub.topics.attachSubscription
• Esegui il pull da una sottoscrizione: pubsub.subscriptions.consume
• Acquistare un abbonamento: pubsub.subscriptions.get
• Elencare un abbonamento: pubsub.subscriptions.list
• Aggiornare un abbonamento: pubsub.subscriptions.update
• Eliminare una sottoscrizione: pubsub.subscriptions.delete
• Ottieni il criterio IAM per una sottoscrizione: pubsub.subscriptions.getIamPolicy
• Configura il criterio IAM per un abbonamento: pubsub.subscriptions.setIamPolicy

Potresti anche riuscire a ottenere queste autorizzazioni con ruoli personalizzati altri ruoli predefiniti.

Se hai bisogno di creare Cloud Storage sottoscrizioni in un progetto associate a un argomento in un altro chiedi all'amministratore dell'argomento di concederti anche l'editor Pub/Sub (roles/pubsub.editor) nell'argomento.

Assegna i ruoli Cloud Storage all'account di servizio Pub/Sub

Alcuni servizi Google Cloud dispongono di account di servizio gestiti da Google Cloud, consente ai servizi di accedere alle tue risorse. Questi account di servizio sono noti come agenti di servizio. Pub/Sub crea e gestisce un servizio per ogni progetto nel formato [e-mail].

Per creare un abbonamento Cloud Storage, l'account di servizio Pub/Sub deve disporre dell'autorizzazione per scrivere nel bucket Cloud Storage specifico e leggere i metadati del bucket. Scegli una delle seguenti procedure:

• Concedi le autorizzazioni a livello di bucket. Al bucket Cloud Storage specifico, concedi all'account di servizio Pub/Sub il ruolo Creatore oggetti Storage (roles/storage.objectCreator) e il ruolo Lettore di bucket legacy Storage (roles/storage.legacyBucketReader).

• Se devi concedere i ruoli a livello di progetto, puoi concedere il ruolo Amministratore archiviazione (roles/storage.admin) al progetto contenente il bucket Cloud Storage. Concedi questo ruolo ai Account di servizio Pub/Sub.

Autorizzazioni del bucket

Per concedere i ruoli Creatore oggetti Storage (roles/storage.objectCreator) e Lettore di bucket legacy Storage (roles/storage.legacyBucketReader) a livello di bucket, svolgi i seguenti passaggi:

1. Nella console Google Cloud, vai alla pagina Cloud Storage.

   Vai a Cloud Storage

2. Fai clic sul bucket Cloud Storage in cui desideri scrivere i messaggi.

   Si apre la pagina Dettagli bucket.

3. Nella pagina Dettagli bucket, fai clic sulla scheda Autorizzazioni.

4. Nella sezione Autorizzazioni > Nella scheda Visualizza per entità, fai clic su Concedi l'accesso.

   Viene visualizzata la pagina Concedi l'accesso.

5. Nella sezione Aggiungi entità, inserisci il nome del tuo Pub/Sub l'account di servizio.

   Il formato dell'account di servizio è[e-mail]. Ad esempio, per un progetto con PROJECT_NUMBER=112233445566, l'account di servizio ha il formato [e-mail].

6. In Assegna ruoli > nell'elenco a discesa Seleziona un ruolo inserisci Creator e seleziona il ruolo Creatore oggetti Storage.

7. Fai clic su Aggiungi un altro ruolo.

8. Nel menu a discesa Seleziona un ruolo, inserisci Bucket Reader e seleziona il ruolo Storage Legacy Bucket Reader.

9. Fai clic su Salva.

Autorizzazioni per il progetto

Segui questi passaggi per concedere a Storage Admin Ruolo (roles/storage.admin) a livello di progetto:

1. Nella console Google Cloud, vai alla pagina IAM.

   Vai a IAM

2. Nella scheda Autorizzazioni > Visualizza per entità, fai clic su Concedi accesso.

   Viene visualizzata la pagina Concedi l'accesso.

3. Nella sezione Aggiungi entità, inserisci il nome del tuo account di servizio Pub/Sub.

   Il formato dell'account di servizio è [e-mail]. Ad esempio, per un progetto con PROJECT_NUMBER=112233445566, l'account di servizio è nel formato [e-mail].

4. In Assegna ruoli > nell'elenco a discesa Seleziona un ruolo inserisci Storage Admin e seleziona il ruolo Storage Admin.

5. Fai clic su Salva.

Per ulteriori informazioni su Cloud Storage IAM, consulta Identity and Access Management (IAM) di Cloud Storage.

Proprietà delle sottoscrizioni Cloud Storage

Quando configuri un abbonamento a Cloud Storage, devi specificare le proprietà comuni a tutti i tipi di abbonamento e alcune altre Proprietà specifiche dell'abbonamento a Cloud Storage.

Proprietà delle sottoscrizioni comuni

Scopri di più sulle proprietà di abbonamento comuni che puoi impostare per tutte le sottoscrizioni.

Nome bucket

Prima di creare un bucket Cloud Storage, deve esistere già un bucket abbonamento a Cloud Storage.

I messaggi vengono inviati in batch e archiviati nel bucket Cloud Storage. Un singolo batch o file viene archiviato come oggetto nel bucket.

Il bucket Cloud Storage deve avere Pagamenti a carico del richiedente disattivata.

Per creare un bucket Cloud Storage, consulta Creare bucket.

Prefisso, suffisso e data/ora del nome file

I file Cloud Storage di output generati da Cloud Storage vengono archiviati come oggetti nel bucket Cloud Storage. Il nome dell'oggetto archiviato nel bucket Cloud Storage è del seguente formato: <file-prefix><UTC-date-time>_<uuid><file-suffix>.

L'elenco seguente include i dettagli del formato del file e i campi che puoi personalizzare:

• <file-prefix> è il prefisso del nome file personalizzato. Questo campo è facoltativo.

• <UTC-date-time> è una stringa personalizzabile generata automaticamente in base all'ora in cui viene creato l'oggetto.

• <uuid> è una stringa casuale generata automaticamente per l'oggetto.

• <file-suffix> è il suffisso del nome file personalizzato. Questo è un campo facoltativo. La Il suffisso del nome file non può terminare con "/".

• Puoi modificare il prefisso e il suffisso del nome file:

  • Ad esempio, se il valore del prefisso del nome file è prod_ e il valore di il suffisso del nome file è _archive, il nome di un oggetto di esempio è prod_2023-09-25T04:10:00+00:00_uN1QuE_archive.

  • Se non specifichi il prefisso e il suffisso del nome file, il nome dell'oggetto memorizzato nel bucket Cloud Storage ha il seguente formato: <UTC-date-time>_<uuid>.

  • I requisiti di denominazione degli oggetti Cloud Storage si applicano anche al prefisso e al suffisso del nome del file. Per saperne di più, consulta Informazioni sugli oggetti Cloud Storage.

• Puoi modificare la modalità di visualizzazione della data e dell'ora nel nome file:

  • Matcher data/ora obbligatori che puoi utilizzare solo una volta: year (YYYY o YY), mese (MM), giorno (DD), ora (hh), minuto (mm), secondo (ss). Ad esempio, YY-YYYY o MMM non è valido.

  • Corrispondenza facoltativi che puoi utilizzare una sola volta: separatore data/ora (T) e e la differenza di fuso orario (Z o +00:00).

  • Elementi facoltativi che puoi utilizzare più volte: trattino (-), trattino basso (_), due punti (:) e barra (/).

  • Ad esempio, se il valore del formato data/ora del nome del file è YYYY-MM-DD/hh_mm_ssZ, un nome di oggetto di esempio è prod_2023-09-25/04_10_00Z_uNiQuE_archive.

  • Se il formato della data e dell'ora del nome del file termina con un carattere che non è un'espressione di corrispondenza, questo carattere sostituirà il separatore tra <UTC-date-time> e <uuid>. Ad esempio, se il valore del formato data/ora nome file è YYYY-MM-DDThh_mm_ss-, il nome di un oggetto di esempio è prod_2023-09-25T04_10_00-uNiQuE_archive.

Batch di file

Le iscrizioni a Cloud Storage ti consentono di decidere quando creare un nuovo file di output archiviato come oggetto nel bucket Cloud Storage. Pub/Sub scrive un file di output quando uno dei sono soddisfatte le condizioni di raggruppamento specificate. Di seguito sono riportati i Condizioni di raggruppamento in batch di Cloud Storage:

• Durata massima del batch di archiviazione. Questa impostazione è obbligatoria. L'abbonamento Cloud Storage scrive un nuovo file di output se viene superato il valore specificato per la durata massima. In caso contrario specifica il valore, viene applicato un valore predefinito di 5 minuti. Di seguito sono riportati i valori applicabili per la durata massima:

  • Valore minimo = 1 minuto
  • Valore predefinito = 5 minuti
  • Valore massimo = 10 minuti

• Byte massimi batch di archiviazione. Questa è un'impostazione facoltativa. La La sottoscrizione Cloud Storage scrive un nuovo file di output se è stato superato il valore massimo di byte specificato. Di seguito sono riportate le valori per i byte massimi:

  • Valore minimo = 1 KB
  • Valore massimo = 10 GiB

• Numero massimo di messaggi batch di archiviazione. Questa impostazione è facoltativa. L'abbonamento Cloud Storage scrive un nuovo file di output se viene superato il numero specificato di messaggi massimi. Di seguito sono riportati i valori applicabili per i messaggi massimi:

  • Valore minimo = 1000

Ad esempio, puoi configurare una durata massima di 6 minuti e per un massimo di 2 GB. Se al quarto minuto il file di output raggiunge le dimensioni di 2 GB, Pub/Sub completa il file precedente e inizia a scrivere in un nuovo file.

Una sottoscrizione Cloud Storage potrebbe scrivere su più file in un a un bucket Cloud Storage contemporaneamente. Se hai configurato il tuo abbonamento in modo da creare un nuovo file ogni 6 minuti, potresti notare la creazione di più file Cloud Storage ogni 6 minuti.

In alcune situazioni, Pub/Sub potrebbe iniziare a scrivere in un nuovo prima dell'ora configurata dalle condizioni di raggruppamento dei file. Un file potrebbe anche superare il valore di byte massimi se l'abbonamento riceve messaggi più grandi del valore di byte massimi.

Formato file

Quando crei una sottoscrizione Cloud Storage, puoi specificare il formato dei file di output da archiviare bucket Cloud Storage come Text o Avro.

• Testo: i messaggi vengono archiviati come testo normale. Un carattere di a capo separa un messaggio dal messaggio precedente nel file. Vengono archiviati solo i payload dei messaggi, non gli attributi o altri metadati.

• Avro: i messaggi vengono archiviati in Apache Avro binario. Quando selezioni Avro, puoi attivare le seguenti proprietà aggiuntive:

  • Scrivi metadati: questa opzione ti consente di archiviare i metadati del messaggio insieme al messaggio. I metadati come i campi subscription_name, message_id, publish_time e attributes vengono scritti nei campi di primo livello dell'oggetto Avro di output, mentre tutte le altre proprietà dei messaggi diverse dai dati (ad esempio, una order_key, se presente) vengono aggiunte come voci nella mappa attributes.

    Se l'opzione metadati di scrittura è disattivata, nell'oggetto Avro di output viene scritto solo il payload del messaggio. Ecco lo schema Avro per i messaggi di output con i metadati di scrittura disabilitati:

    {
      "type": "record",
      "namespace": "com.google.pubsub",
      "name": "PubsubMessage",
      "fields": [
        { "name": "data", "type": "bytes" }
      ]
    }
    

    Ecco lo schema Avro per i messaggi di output con metadati di scrittura abilitati:

    {
      "type": "record",
      "namespace": "com.google.pubsub",
      "name": "PubsubMessageWithMetadata",
      "fields": [
        { "name": "subscription_name", "type": "string" },
        { "name": "message_id", "type": "string"  },
        { "name": "publish_time", "type": {
            "type": "long",
            "logicalType": "timestamp-micros"
          }
        },
        { "name": "attributes", "type": { "type": "map", "values": "string" } },
        { "name": "data", "type": "bytes" }
      ]
    }
    

  • Utilizza schema argomento: questa opzione consente a Pub/Sub di utilizzare lo schema schema dell'argomento Pub/Sub a cui l'abbonamento è allegato quando scrivi file Avro.

    Quando utilizzi questa opzione, ricordati di verificare i seguenti requisiti aggiuntivi:

    • Lo schema dell'argomento deve essere in formato Apache Avro.

    • Se sono abilitate le opzioni Utilizza schema argomento e Scrivi metadati, lo schema dell'argomento deve avere un oggetto Record nella directory principale. Pub/Sub espande l'elenco dei campi del record in modo da includere i campi dei metadati. Di conseguenza, il record non può contenere campi con lo stesso nome dei campi dei metadati (subscription_name, message_id, publish_time o attributes).

Crea una sottoscrizione Cloud Storage

Console

1. Nella console Google Cloud, vai alla pagina Abbonamenti. .

   Vai ad Abbonamenti

2. Fai clic su Crea sottoscrizione.

3. Inserisci un nome nel campo Subscription ID (ID abbonamento).

   Per informazioni su come assegnare un nome a una sottoscrizione, vedere Linee guida per assegnare un nome a un argomento un abbonamento.

4. Scegli o crea un argomento dal menu a discesa.

   La sottoscrizione riceve i messaggi dall'argomento.

   Per informazioni su come creare un argomento, vedi Creare e gestire argomenti.

5. Seleziona Tipo di recapito come Scrivi in Cloud Storage.

6. Per il bucket Cloud Storage, fai clic su Sfoglia.

   • Puoi selezionare un bucket esistente da qualsiasi progetto appropriato.

   • Puoi anche fare clic sull'icona di creazione e seguire le istruzioni sullo schermo per creare un nuovo bucket.

     Dopo aver creato il bucket, selezionalo per l'abbonamento Cloud Storage.

     Per scoprire di più su come creare un bucket, consulta Creare bucket.

   Quando specifichi il bucket, Pub/Sub verifica la presenza di le autorizzazioni appropriate sul bucket per Pub/Sub l'account di servizio. In caso di problemi relativi alle autorizzazioni, viene visualizzato un messaggio. simile al seguente: Unable to verify if the Pub/Sub service agent has write permissions on this bucket. You may be lacking permissions to view or set permissions.

7. Se riscontri problemi di autorizzazione, fai clic su Imposta autorizzazione e segui le istruzioni sullo schermo.

   In alternativa, segui le istruzioni riportate in Assegnare i ruoli Cloud Storage all'account di servizio Pub/Sub.

8. In Formato file, seleziona Testo oppure Avro.

   Se selezioni Avro, puoi anche specificare se vuoi archiviare i metadati del messaggio nell'output.

   Per ulteriori informazioni sulle due opzioni, incluso il messaggio l'opzione dei metadati per il formato Avro, consulta la sezione File standard.

9. (Facoltativo) Puoi specificare il prefisso, il suffisso e la data e l'ora del nome del file per tutti i file da scrivere nel bucket Cloud Storage. Un file viene archiviato come oggetto nel bucket.

   Per ulteriori informazioni su come impostare prefisso, suffisso e data/ora, vedi Prefisso, suffisso e data/ora.

10. Per l'aggregazione di file, specifica un tempo massimo che deve trascorrere prima di creare un nuovo file.

    Se vuoi, puoi anche impostare le dimensioni massime del file o il numero massimo di messaggi per i file.

    Per ulteriori informazioni su entrambe le opzioni di raggruppamento dei file, vedi Raggruppamento dei file.

11. Ti consigliamo vivamente di attivare i messaggi non recapitabili per gestire gli errori dei messaggi.

    Per ulteriori informazioni, consulta Lettera non recapitabile .

12. Puoi mantenere le altre impostazioni predefinite e fare clic su Crea.

gcloud

1. In the Google Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

2. Per creare una sottoscrizione Cloud Storage, esegui il comando gcloud pubsub subscriptions create.

   gcloud pubsub subscriptions create SUBSCRIPTION_ID \
       --topic=TOPIC_ID \
       --cloud-storage-bucket=BUCKET_NAME \
       --cloud-storage-file-prefix=CLOUD_STORAGE_FILE_PREFIX \
       --cloud-storage-file-suffix=CLOUD_STORAGE_FILE_SUFFIX \
       --cloud-storage-file-datetime-format=CLOUD_STORAGE_FILE_DATETIME_FORMAT \
       --cloud-storage-max-duration=CLOUD_STORAGE_MAX_DURATION \
       --cloud-storage-max-bytes=CLOUD_STORAGE_MAX_BYTES \
       --cloud-storage-max-messages=CLOUD_STORAGE_MAX_MESSAGES \
       --cloud-storage-output-format=CLOUD_STORAGE_OUTPUT_FORMAT \
       --cloud-storage-write-metadata
       --cloud-storage-use-topic-schema

   Nel comando sono obbligatori solo SUBSCRIPTION_ID, il --topic e il --cloud-storage-bucket. I flag rimanenti sono facoltativi e possono essere omessi.

   Sostituisci quanto segue:

   • SUBSCRIPTION_ID: il nome o l'ID del nuovo elemento abbonamento a Cloud Storage.
   • TOPIC_ID: il nome o l'ID dell'argomento.
   • BUCKET_NAME: specifica il nome di un di un bucket esistente. Ad esempio, prod_bucket. Il bucket non deve includere l'ID progetto. Per creare un bucket, consulta Creare bucket.
   • CLOUD_STORAGE_FILE_PREFIX: specifica il prefisso per il nome del file di Cloud Storage. Ad esempio: log_events_.
   • CLOUD_STORAGE_FILE_SUFFIX: specifica il parametro per il nome file Cloud Storage. Ad esempio, .txt.
   • CLOUD_STORAGE_FILE_DATETIME_FORMAT: Specifica il formato data e ora per il nome del file di Cloud Storage. Ad esempio, YYYY-MM-DD/hh_mm_ssZ.
   • CLOUD_STORAGE_MAX_DURATION: la soglia massima tempo che può trascorrere prima che un nuovo file Cloud Storage venga è stato creato. Il valore deve essere compreso tra 1 m e 10 m. Ad esempio, 5m.
   • CLOUD_STORAGE_MAX_BYTES: il numero massimo di byte che possono essere scritti in un file Cloud Storage prima che venga creato un nuovo file. Il valore deve essere compreso tra 1 KB e 10 GB. Ad esempio, 20MB.
   • CLOUD_STORAGE_MAX_MESSAGES: il numero massimo di messaggi che possono essere scritti in un file Cloud Storage prima che venga creato un nuovo file. Il valore deve essere maggiore o uguale a 1000. Ad esempio, 100000.
   • CLOUD_STORAGE_OUTPUT_FORMAT: l'output per i dati scritti in Cloud Storage. I valori sono:
     • text: i messaggi vengono scritti come testo non elaborato, separati da una nuova riga.
     • avro: i messaggi vengono scritti come file binario Avro. --cloud-storage-write-metadata e Solo --cloud-storage-use-topic-schema interessati richieste con formato di output avro.

C++

Prima di provare questo esempio, segui le istruzioni di configurazione di C++ riportate nella guida rapida di Pub/Sub che utilizza le librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.

Per eseguire l'autenticazione su Pub/Sub, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per le librerie client.

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& bucket) {
  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_cloud_storage_config()->set_bucket(bucket);
  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";
}

Go

Prima di provare questo esempio, segui le istruzioni per la configurazione di Go nel Guida rapida di Pub/Sub con librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per le librerie client.

import (
	"context"
	"fmt"
	"io"
	"time"

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

// createCloudStorageSubscription creates a Pub/Sub subscription that exports messages to Cloud Storage.
func createCloudStorageSubscription(w io.Writer, projectID, subID string, topic *pubsub.Topic, bucket string) error {
	// projectID := "my-project-id"
	// subID := "my-sub"
	// topic of type https://godoc.org/cloud.google.com/go/pubsub#Topic
	// note bucket should not have the gs:// prefix
	// bucket := "my-bucket"
	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,
		CloudStorageConfig: pubsub.CloudStorageConfig{
			Bucket:         bucket,
			FilenamePrefix: "log_events_",
			FilenameSuffix: ".avro",
			OutputFormat:   &pubsub.CloudStorageOutputFormatAvroConfig{WriteMetadata: true},
			MaxDuration:    1 * time.Minute,
			MaxBytes:       1e8,
		},
	})
	if err != nil {
		return fmt.Errorf("client.CreateSubscription: %w", err)
	}
	fmt.Fprintf(w, "Created Cloud Storage subscription: %v\n", sub)

	return nil
}

Java

Prima di provare questo esempio, segui le istruzioni per la configurazione di Java nel Guida rapida di Pub/Sub con librerie client. Per ulteriori informazioni, consulta API Pub/Sub Java documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per saperne di più, consulta Configurare l'autenticazione per le librerie client.

import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
import com.google.protobuf.Duration;
import com.google.pubsub.v1.CloudStorageConfig;
import com.google.pubsub.v1.ProjectSubscriptionName;
import com.google.pubsub.v1.ProjectTopicName;
import com.google.pubsub.v1.Subscription;
import java.io.IOException;

public class CreateCloudStorageSubscriptionExample {
  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 bucket = "your-bucket";
    String filenamePrefix = "log_events_";
    String filenameSuffix = ".text";
    Duration maxDuration = Duration.newBuilder().setSeconds(300).build();

    createCloudStorageSubscription(
        projectId, topicId, subscriptionId, bucket, filenamePrefix, filenameSuffix, maxDuration);
  }

  public static void createCloudStorageSubscription(
      String projectId,
      String topicId,
      String subscriptionId,
      String bucket,
      String filenamePrefix,
      String filenameSuffix,
      Duration maxDuration)
      throws IOException {
    try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {

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

      CloudStorageConfig cloudStorageConfig =
          CloudStorageConfig.newBuilder()
              .setBucket(bucket)
              .setFilenamePrefix(filenamePrefix)
              .setFilenameSuffix(filenameSuffix)
              .setMaxDuration(maxDuration)
              .build();

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

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

Monitorare una sottoscrizione Cloud Storage

Cloud Monitoring fornisce una serie di metriche per monitorare gli abbonamenti.

Per un elenco di tutte le metriche disponibili relative a Pub/Sub e le relative descrizioni, consulta la documentazione di monitoraggio per Pub/Sub.

Puoi anche monitorare le sottoscrizioni all'interno di Pub/Sub.

Passaggi successivi

• Risolvi i problemi relativi a un abbonamento a Cloud Storage.

• Scopri di più su Cloud Storage.

• Consulta i prezzi di Pub/Sub, incluso l'abbonamento a Cloud Storage.