文件名称:kinesis-producer:Amazon Kinesis的汇总记录生产者
文件大小:17KB
文件格式:ZIP
更新时间:2024-05-27 05:02:46
go kinesis amazon-kinesis producer kpl
亚马逊运动产生器 在官方Go AWS开发工具包的基础上构建的Amazon Kinesis的类似于KPL的批处理生产器并使用与使用的聚合格式相同的聚合格式。 有用的链接 例子 package main import ( "time" "github.com/sirupsen/logrus" "github.com/a8m/kinesis-producer" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/kinesis" ) func main () { client := kinesis . New ( session . New ( aws . NewConfig ())) pr := producer .
【文件预览】:
kinesis-producer-master
----.gitignore(6B)
----go.mod(434B)
----aggregator.go(3KB)
----messages.pb.go(5KB)
----semaphore.go(418B)
----.travis.yml(67B)
----producer.go(8KB)
----LICENSE(882B)
----producer_test.go(5KB)
----example_test.go(824B)
----README.md(3KB)
----loggers()
--------kpzap()
--------kplogrus()
----aggregation-format.md(2KB)
----aggregator_test.go(1KB)
----logger.go(1KB)
----config.go(3KB)
----messages.proto(472B)