删除订阅

namespace pubsub_admin = ::google::cloud::pubsub_admin; namespace pubsub = ::google::cloud::pubsub; [](pubsub_admin::SubscriptionAdminClient client,    std::string const& project_id, std::string const& subscription_id) {   auto status = client.DeleteSubscription(       pubsub::Subscription(project_id, subscription_id).FullName());   // Note that kNotFound is a possible result when the library retries.   if (status.code() == google::cloud::StatusCode::kNotFound) {     std::cout << "The subscription was not found\n";     return;   }   if (!status.ok()) throw std::runtime_error(status.message());    std::cout << "The subscription was successfully deleted\n";

 using Google.Cloud.PubSub.V1;  public class DeleteSubscriptionSample {     public void DeleteSubscription(string projectId, string subscriptionId)     {         SubscriberServiceApiClient subscriber = SubscriberServiceApiClient.Create();         SubscriptionName subscriptionName = SubscriptionName.FromProjectSubscription(projectId, subscriptionId);         subscriber.DeleteSubscription(subscriptionName);     } }

import ( 	"context" 	"fmt" 	"io"  	"cloud.google.com/go/pubsub/v2" 	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb" )  func delete(w io.Writer, projectID, subID string) error { 	// projectID := "my-project-id" 	// subID := "my-sub" 	ctx := context.Background() 	client, err := pubsub.NewClient(ctx, projectID) 	if err != nil { 		return fmt.Errorf("pubsub.NewClient: %w", err) 	} 	defer client.Close()  	req := &pubsubpb.DeleteSubscriptionRequest{ 		Subscription: fmt.Sprintf("projects/%s/subscriptions/%s", projectID, subID), 	} 	if err := client.SubscriptionAdminClient.DeleteSubscription(ctx, req); err != nil { 		return fmt.Errorf("Delete: %w", err) 	} 	fmt.Fprintf(w, "Subscription %q deleted.", subID) 	return nil } 

 import com.google.api.gax.rpc.NotFoundException; import com.google.cloud.pubsub.v1.SubscriptionAdminClient; import com.google.pubsub.v1.SubscriptionName; import java.io.IOException;  public class DeleteSubscriptionExample {    public static void main(String... args) throws Exception {     // TODO(developer): Replace these variables before running the sample.     String projectId = "your-project-id";     String subscriptionId = "your-subscription-id";      deleteSubscriptionExample(projectId, subscriptionId);   }    public static void deleteSubscriptionExample(String projectId, String subscriptionId)       throws IOException {     try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {       SubscriptionName subscriptionName = SubscriptionName.of(projectId, subscriptionId);       try {         subscriptionAdminClient.deleteSubscription(subscriptionName);         System.out.println("Deleted subscription.");       } catch (NotFoundException e) {         System.out.println(e.getMessage());       }     }   } }

/**  * TODO(developer): Uncomment this variable before running the sample.  */ // const subscriptionNameOrId = 'YOUR_SUBSCRIPTION_NAME_OR_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 deleteSubscription(subscriptionNameOrId) {   // Deletes the subscription   await pubSubClient.subscription(subscriptionNameOrId).delete();   console.log(`Subscription ${subscriptionNameOrId} deleted.`); }

/**  * TODO(developer): Uncomment this variable before running the sample.  */ // const subscriptionNameOrId = 'YOUR_SUBSCRIPTION_NAME_OR_ID';  // Imports the Google Cloud client library import {PubSub} from '@google-cloud/pubsub';  // Creates a client; cache this for further use const pubSubClient = new PubSub();  async function deleteSubscription(subscriptionNameOrId: string) {   // Deletes the subscription   await pubSubClient.subscription(subscriptionNameOrId).delete();   console.log(`Subscription ${subscriptionNameOrId} deleted.`); }

use Google\Cloud\PubSub\PubSubClient;  /**  * Creates a Pub/Sub subscription.  *  * @param string $projectId  The Google project ID.  * @param string $subscriptionName  The Pub/Sub subscription name.  */ function delete_subscription($projectId, $subscriptionName) {     $pubsub = new PubSubClient([         'projectId' => $projectId,     ]);     $subscription = $pubsub->subscription($subscriptionName);     $subscription->delete();      printf('Subscription deleted: %s' . PHP_EOL, $subscription->name()); }

from google.cloud import pubsub_v1  # TODO(developer) # project_id = "your-project-id" # subscription_id = "your-subscription-id"  subscriber = pubsub_v1.SubscriberClient() subscription_path = subscriber.subscription_path(project_id, subscription_id)  # Wrap the subscriber in a 'with' block to automatically call close() to # close the underlying gRPC channel when done. with subscriber:     subscriber.delete_subscription(request={"subscription": subscription_path})  print(f"Subscription deleted: {subscription_path}.")

# subscription_id = "your-subscription-id"  pubsub = Google::Cloud::PubSub.new subscription_admin = pubsub.subscription_admin  subscription_admin.delete_subscription \   subscription: pubsub.subscription_path(subscription_id)  puts "Subscription #{subscription_id} deleted."