From 724060b3464524ddd1c6bc7e3d0e30882c311a8d Mon Sep 17 00:00:00 2001 From: skozawa Date: Fri, 26 Mar 2021 17:05:31 +0900 Subject: [PATCH] =?UTF-8?q?AWS=5FENDPOINT=E6=8C=87=E5=AE=9A=E3=81=A7?= =?UTF-8?q?=E3=81=8D=E3=82=8B=E3=82=88=E3=81=86=E3=81=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/main.go b/main.go index afff9d7..4a7f77f 100644 --- a/main.go +++ b/main.go @@ -137,7 +137,15 @@ func main() { } // kinsumer - sess := session.Must(session.NewSession(aws.NewConfig())) + var sess *session.Session + if len(os.Getenv("AWS_ENDPOINT")) != 0 { + sess = session.Must(session.NewSession(&aws.Config{ + Endpoint: aws.String(os.Getenv("AWS_ENDPOINT")), + S3ForcePathStyle: aws.Bool(true), + })) + } else { + sess = session.Must(session.NewSession(aws.NewConfig())) + } k, err := kinsumer.NewWithSession( sess, kinesisStreamName,