我正在使用gcp-pub/sub。若在接受新邮件时出现异常,我会将其放入死信队列。我希望在审阅后有机会重新处理邮件。我尝试使用Dataflow,但它只是在到达死信队列时立即发送消息。有什么建议我该怎么解决吗?
对于临时解决方案,可以使用数据流将死信主题中的数据导出到BigQuery。查看数据后,使用任何组件处理数据并从BigQuery将数据重新导出到pubsub。通过这种方式,您可以控制何时导出数据。我知道这并不理想。但短期内会有所帮助。
我正在使用gcp-pub/sub。若在接受新邮件时出现异常,我会将其放入死信队列。我希望在审阅后有机会重新处理邮件。我尝试使用Dataflow,但它只是在到达死信队列时立即发送消息。有什么建议我该怎么解决吗?
对于临时解决方案,可以使用数据流将死信主题中的数据导出到BigQuery。查看数据后,使用任何组件处理数据并从BigQuery将数据重新导出到pubsub。通过这种方式,您可以控制何时导出数据。我知道这并不理想。但短期内会有所帮助。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium