From c5c7dd49c97926b1a267b2681afc1fd236180442 Mon Sep 17 00:00:00 2001 From: dan Date: Sun, 29 Mar 2015 12:22:29 -0700 Subject: [PATCH] add / between bucket and filename in copy statement --- redshift_basic_emitter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redshift_basic_emitter.go b/redshift_basic_emitter.go index 7c48d22..d1d9b6e 100644 --- a/redshift_basic_emitter.go +++ b/redshift_basic_emitter.go @@ -48,7 +48,7 @@ func (e RedshiftBasicEmtitter) Emit(b Buffer, t Transformer) { func (e RedshiftBasicEmtitter) copyStatement(s3File string) string { b := new(bytes.Buffer) b.WriteString(fmt.Sprintf("COPY %v ", e.TableName)) - b.WriteString(fmt.Sprintf("FROM 's3://%v%v' ", e.S3Bucket, s3File)) + b.WriteString(fmt.Sprintf("FROM 's3://%v/%v' ", e.S3Bucket, s3File)) b.WriteString(fmt.Sprintf("CREDENTIALS 'aws_access_key_id=%v;", os.Getenv("AWS_ACCESS_KEY"))) b.WriteString(fmt.Sprintf("aws_secret_access_key=%v' ", os.Getenv("AWS_SECRET_KEY"))) switch e.Format {