in test-sending-tool/main.go [28:55]
func main() {
filenamePtr := flag.String("file", "", "File whose contents will be sent")
streamNamePtr := flag.String("stream", "", "Stream to send the data to")
flag.Parse()
//get credentails from default chain - https://docs.aws.amazon.com/sdk-for-go/api/
sess, sessionErr := session.NewSession()
if sessionErr != nil {
log.Fatal("Could not set up AWS session: ", sessionErr)
}
svc := kinesis.New(sess)
contentPtr := get_file(*filenamePtr)
partKey := "1"
rq := &kinesis.PutRecordInput{
Data: *contentPtr,
PartitionKey: &partKey,
StreamName: streamNamePtr,
}
log.Printf("Sending to %s", *streamNamePtr)
_, sendErr := svc.PutRecord(rq)
if sendErr != nil {
log.Fatal("Could not send to stream: ", sendErr)
}
log.Print("Successfully sent")
}