luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

more log4go additions

Browse source
This commit is contained in:
dan 2015-04-03 23:14:08 -07:00
parent b89c69d86b
commit d746c2529a
2 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
kinesis.go
View file

@ -1,10 +1,10 @@
package connector
import (
"fmt"
"time"
"github.com/ezoic/go-kinesis"
l4g "github.com/ezoic/sol/log4go"
)
// CreateStream creates a new Kinesis stream (uses existing stream if exists) and
@ -14,7 +14,7 @@ func CreateStream(k *kinesis.Kinesis, streamName string, shardCount int) {
err := k.CreateStream(streamName, shardCount)
if err != nil {
fmt.Printf("CreateStream ERROR: %v\n", err)
l4g.Error("CreateStream ERROR: %v", err)
return
}
}
@ -27,7 +27,7 @@ func CreateStream(k *kinesis.Kinesis, streamName string, shardCount int) {
args.Add("StreamName", streamName)
resp, _ = k.DescribeStream(args)
streamStatus := resp.StreamDescription.StreamStatus
fmt.Printf("Stream [%v] is %v\n", streamName, streamStatus)
l4g.Info("Stream [%v] is %v", streamName, streamStatus)
if streamStatus != "ACTIVE" {
time.Sleep(4 * time.Second)
@ -43,7 +43,7 @@ func StreamExists(k *kinesis.Kinesis, streamName string) bool {
args := kinesis.NewArgs()
resp, err := k.ListStreams(args)
if err != nil {
fmt.Printf("ListStream ERROR: %v\n", err)
l4g.Error("ListStream ERROR: %v", err)
return false
}
for _, s := range resp.StreamNames {

2
redshift_manifest_emitter.go
View file

@ -123,7 +123,7 @@ func (e RedshiftManifestEmitter) writeManifestToS3(files []string, manifestFileN
content := e.generateManifestFile(files)
err := bucket.Put(manifestFileName, content, "text/plain", s3.Private, s3.Options{})
if err != nil {
fmt.Printf("Error occured while uploding to S3: %v\n", err)
l4g.Error("Error occured while uploding to S3: %v", err)
}
}