golang小白一枚,正在不断学习积累知识,现将学习到的知识记录一下,也是将我的所得分享给大家!而今天这篇文章《使用 kafka 使用队列处理 csv 文件以插入到 postgres 数据库并返回状
golang小白一枚,正在不断学习积累知识,现将学习到的知识记录一下,也是将我的所得分享给大家!而今天这篇文章《使用 kafka 使用队列处理 csv 文件以插入到 postgres 数据库并返回状态消息》带大家来了解一下##content_title##,希望对大家的知识积累有所帮助,从而弥补自己的不足,助力实战开发!
我正在寻找一些最佳实践/建议来处理 csv 文件,以便使用队列机制(kafka)插入数据库
所以我要做什么:
创建一个新的sql表service request
来存储用户请求的信息,例如:
RequestID, Status, Payload, Response
如您所见,我有字段 status
来指示请求是成功或失败
这是用户上传 csv 文件时的流程:
service request
表上创建一条新记录,负载为 csv 文件的网址在消费者方面:
status
并使用 csv 文件错误列表设置响应所以问题是: 如何知道所有queue的requestid xxx 已全部消耗完,我可以更新状态吗?
我正在使用: go + confluence-kafka-go 库
更新
经过一些研究,我发现它应该通过实现 groupbykey
来使用 kafka stream,在 go 中可以做到这一点吗?我无法从 confluence-kafka-go
我是 Kafka 新手,所以我可能不是提供建议的最佳人选,但我最初的反应是强制消息处理“按顺序”发生。在生产者方面,您将指示最后一条消息。在消费者方面,您将读取指示器,一旦到达最后一条消息,您将更新 Status
字段。请记住,强制消息顺序可能会对系统吞吐量产生影响。
有用的阅读可拨打 https://medium.com/latentview-data-services/how-to-use-apache-kafka-to-guarantee-message-ordering-ac2d00da6c22
另一种方法是使用 Postgres 作为分布式锁并跟踪进度。例如,假设您有一个包含以下列的跟踪表:RequestId
、RecordsProcessed
、RecordsGenerate
。每次使用消息时,您都会锁定行或表并递增 RecordsProcessed
列。处理完所有记录后,您将相应地更新 Status
。
理论要掌握,实操不能落!以上关于《使用 Kafka 使用队列处理 csv 文件以插入到 postgres 数据库并返回状态消息》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注编程网公众号吧!
--结束END--
本文标题: 使用 Kafka 使用队列处理 csv 文件以插入到 postgres 数据库并返回状态消息
本文链接: https://www.lsjlt.com/news/596839.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-04-05
2024-04-05
2024-04-05
2024-04-04
2024-04-05
2024-04-05
2024-04-05
2024-04-05
2024-04-04
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
一口价域名售卖能注册吗?域名是网站的标识,简短且易于记忆,为在线用户提供了访问我们网站的简单路径。一口价是在域名交易中一种常见的模式,而这种通常是针对已经被注册的域名转售给其他人的一种方式。
一口价域名买卖的过程通常包括以下几个步骤:
1.寻找:买家需要在域名售卖平台上找到心仪的一口价域名。平台通常会为每个可售的域名提供详细的描述,包括价格、年龄、流
443px" 443px) https://www.west.cn/docs/wp-content/uploads/2024/04/SEO图片294.jpg https://www.west.cn/docs/wp-content/uploads/2024/04/SEO图片294-768x413.jpg 域名售卖 域名一口价售卖 游戏音频 赋值/切片 框架优势 评估指南 项目规模
0