Maison > développement back-end > Golang > Les paramètres de Google Pub/Sub activent par programmation la conservation des messages pour les sujets

Les paramètres de Google Pub/Sub activent par programmation la conservation des messages pour les sujets

WBOY
Libérer: 2024-02-09 08:10:08
avant
1227 Les gens l'ont consulté

Google Pub/Sub 设置以编程方式启用主题的消息保留

l'éditeur php Xigua vous apporte de nouvelles compétences sur Google Pub/Sub. Vous pouvez désormais définir la conservation des messages par programme pour garantir que les messages de votre sujet ne sont pas perdus. Il s'agit d'une fonctionnalité très utile, en particulier lorsque vous travaillez avec des données importantes ou des tâches nécessitant de longs temps de traitement. En activant la conservation des messages, vous pouvez traiter les messages en toute confiance sans craindre qu'ils ne soient perdus au cours du processus. Nous détaillerons ensuite comment activer par programmation la conservation des messages pour un sujet à l'aide des paramètres de Google Pub/Sub. Restez à l'écoute!

Contenu des questions

Dans Google pub/sub, si un sujet est créé, nous pouvons définir une politique de rétention

https://console.cloud.google.com/cloudpubsub

En cliquant, en éditant, en éditant le thème, en mettant à jour

Est-il possible de mettre à jour cette valeur par programmation ?

J'ai vu que le niveau d'abonnement a cette configuration https://github.com/googleapis/google-cloud-go/blob/main/pubsub/subscription.go#L564 Mais pas au niveau du sujet ?

Solution de contournement

Oui, la conservation des messages peut être configurée par programme dans le sujet. Dans Go, vous pouvez configurer RetentionDurationTopicConfig 中并将其传递给 CreateTopicWithConfig pour qu'il fasse ceci lors de la création :

tc := TopicConfig{
    RetentionDuration = 168 * time.Hour
}
topic, err := c.CreateTopicWithConfig(context.Background(), "my-topic", tc)
Copier après la connexion

Pour ce faire lors de la mise à jour, rendez-vous sur TopicConfigToUpdate 中设置属性并将其传递给 Update :

topic := client.Topic("my-topic")
topicConfig, err := topic.Update(ctx, pubsub.TopicConfigToUpdate{
  RetentionDuration = 168 * time.Hour
})
Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

source:stackoverflow.com
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal