Aggiorna una prenotazione Pub/Sub Lite
Per saperne di più
Per la documentazione dettagliata che include questo esempio di codice, vedi quanto segue:
Esempio di codice
Go
import (
"context"
"fmt"
"io"
"cloud.google.com/go/pubsublite"
)
func updateReservation(w io.Writer, projectID, region, reservationID string, throughputCapacity int) error {
// projectID := "my-project-id"
// region := "us-central1"
// reservationID := "my-reservation-id"
// throughputCapacity := 8
ctx := context.Background()
client, err := pubsublite.NewAdminClient(ctx, region)
if err != nil {
return fmt.Errorf("pubsublite.NewAdminClient: %v", err)
}
defer client.Close()
reservationPath := fmt.Sprintf("projects/%s/locations/%s/reservations/%s", projectID, region, reservationID)
config := pubsublite.ReservationConfigToUpdate{
Name: reservationPath,
ThroughputCapacity: throughputCapacity,
}
updatedCfg, err := client.UpdateReservation(ctx, config)
if err != nil {
return fmt.Errorf("client.UpdateReservation got err: %v", err)
}
fmt.Fprintf(w, "Updated reservation: %#v\n", updatedCfg)
return nil
}
Java
import com.google.api.gax.rpc.NotFoundException;
import com.google.cloud.pubsublite.AdminClient;
import com.google.cloud.pubsublite.AdminClientSettings;
import com.google.cloud.pubsublite.CloudRegion;
import com.google.cloud.pubsublite.ProjectNumber;
import com.google.cloud.pubsublite.ReservationName;
import com.google.cloud.pubsublite.ReservationPath;
import com.google.cloud.pubsublite.proto.Reservation;
import java.util.concurrent.ExecutionException;
public class UpdateReservationExample {
public static void main(String... args) throws Exception {
// TODO(developer): Replace these variables before running the sample.
long projectNumber = Long.parseLong("123456789");
String cloudRegion = "your-cloud-region";
String reservationId = "your-reservation-id";
// Each unit of throughput capacity supports up to 1 MiB/s of published messages or
// 2 MiB/s of subscribed messages.
int throughputCapacity = 8;
updateReservationExample(projectNumber, cloudRegion, reservationId, throughputCapacity);
}
public static void updateReservationExample(
long projectNumber, String cloudRegion, String reservationId, int throughputCapacity)
throws Exception {
ReservationPath reservationPath =
ReservationPath.newBuilder()
.setProject(ProjectNumber.of(projectNumber))
.setLocation(CloudRegion.of(cloudRegion))
.setName(ReservationName.of(reservationId))
.build();
com.google.protobuf.FieldMask fieldMask =
com.google.protobuf.FieldMask.newBuilder().addPaths("throughput_capacity").build();
Reservation reservation =
Reservation.newBuilder()
.setName(reservationPath.toString())
.setThroughputCapacity(throughputCapacity)
.build();
AdminClientSettings adminClientSettings =
AdminClientSettings.newBuilder().setRegion(CloudRegion.of(cloudRegion)).build();
try (AdminClient adminClient = AdminClient.create(adminClientSettings)) {
Reservation reservationBeforeUpdate = adminClient.getReservation(reservationPath).get();
System.out.println("Before update: " + reservationBeforeUpdate.getAllFields());
Reservation reservationAfterUpdate =
adminClient.updateReservation(reservation, fieldMask).get();
System.out.println("After update: " + reservationAfterUpdate.getAllFields());
} catch (ExecutionException e) {
try {
throw e.getCause();
} catch (NotFoundException notFound) {
System.out.println("This reservation is not found.");
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
}
}Python
from google.api_core.exceptions import NotFound
from google.cloud.pubsublite import AdminClient, Reservation
from google.cloud.pubsublite.types import CloudRegion, ReservationPath
from google.protobuf.field_mask_pb2 import FieldMask
# TODO(developer):
# project_number = 1122334455
# cloud_region = "us-central1"
# reservation_id = "your-reservation-id"
# Each unit of throughput capacity supports up to 1 MiB/s of published messages
# or 2 MiB/s of subscribed messages. Must be a positive integer.
# throughput_capacity = 8
cloud_region = CloudRegion(cloud_region)
reservation_path = ReservationPath(project_number, cloud_region, reservation_id)
# Defines which fields to update in the reservation.
field_mask = FieldMask(paths=["throughput_capacity"])
reservation = Reservation(
name=str(reservation_path), throughput_capacity=throughput_capacity
)
client = AdminClient(cloud_region)
try:
response = client.get_reservation(reservation_path)
print(f"Before update: {response}")
response = client.update_reservation(reservation, field_mask)
print(f"After update: {response}")
except NotFound:
print(f"{reservation_path} is not found.")Passaggi successivi
Per cercare e filtrare esempi di codice per altri prodotti Google Cloud, consulta il browser di esempio Google Cloud.