AWS Firehose 和 Go 问题

Question

我正在尝试将一个简单的文件发送到 Go 中的 Firehose 并不断收到：

panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xb code=0x1 addr=0x0 pc=0x4015b7]

goroutine 1 [running]:
panic(0x8b9260, 0xc82000a0e0)
    /usr/lib/go-1.6/src/runtime/panic.go:481 +0x3e6
main.main()
    /home/ubuntu/go/src/github.com/user/proj/txtParser.go:68 +0x5b7
exit status 2

下面是小脚本

package main

import (
"fmt"
"github.com/aws/aws-sdk-go/service/firehose"
"github.com/aws/aws-sdk-go/aws/session"
"io/ioutil"
"log"   
)

func main() {

  sess := session.Must(session.NewSession())

  svc := firehose.New(sess)

  firehoseData, err := ioutil.ReadFile("/tmp/adsDat1")

  if err != nil {
    log.Fatal(err)
  }

  var rec *firehose.Record

  var recInput *firehose.PutRecordInput

  rec.SetData(firehoseData)
  recInput.SetDeliveryStreamName("test-ads-txt")
  recInput.SetRecord(rec)

  res, err1 := svc.PutRecord(recInput)

  if err1 != nil {
   log.Fatal(err1)
  }
  fmt.Println(res)
}

关于正在发生的事情的任何想法我确信这很简单，但我已经盯着它看太久了，似乎无法弄清楚。

Answer 1

明白了，我使用类型的指针声明我的变量，而不是使用类型声明我的变量。看看下面应该如何

 var rec firehose.Record

 var recInput firehose.PutRecordInput

还将地址添加到这些而不是变量

 recInput.SetRecord(&rec)

 res, err1 := svc.PutRecord(&recInput)

而且有效。

AWS Firehose 和 Go 问题

AWS Firehose and Go Issue

go

amazon-web-services

amazon-kinesis-firehose