文件名称:nsq-to-s3:将NSQ通道流式传输到S3
文件大小:11KB
文件格式:ZIP
更新时间:2024-06-07 23:06:56
Go
nsq到s3 将NSQ通道流式传输到S3 参数 主题:要订阅的NSQ主题 频道:要使用的NSQ频道名称(默认为自动生成的临时频道) max-in-flight:允许的未完成邮件的最大数量(有效的批量大小) max-in-flight-time:在刷新之前等待的最大秒数(以防maxInFlight不够用) lookupd-http-address:要连接到的NSQLookup守护程序的地址 nsqd-tcp-address:要连接到的特定NSQ守护程序 bucket-seconds:如果我们不首先点击bucketMessages,则要在S3上结束的每个文件的时间桶大小(例如3600将每小时为您提供一个文件在S3上) bucket-messages:要存储到桶中的消息总数(如果不首先经过bucketSeconds) s3bucket:用于存储文件的S3存储桶(例如“ nsq-arc
【文件预览】:
nsq-to-s3-master
----.gitignore(277B)
----store_messages.go(2KB)
----handler_abandoned_channel.go(2KB)
----deb()
--------DEBIAN()
----handler_on_disk.go(4KB)
----handler_in_memory.go(2KB)
----LICENSE(1KB)
----main.go(4KB)
----README.md(3KB)
----process_arguments.go(3KB)