Maison  >  Article  >  développement back-end  >  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
WBOYavant
2024-02-09 08:10:081178parcourir

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)

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
})

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!

Déclaration:
Cet article est reproduit dans:. en cas de violation, veuillez contacter admin@php.cn Supprimer