我正在尝试将一个简单的文件发送到 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)
}
关于正在发生的事情的任何想法我确信这很简单,但我已经盯着它看太久了,似乎无法弄清楚。
最佳答案
弄清楚了,我使用类型的指针声明我的变量,而不是使用类型声明我的变量。看看下面应该如何
var rec firehose.Record
var recInput firehose.PutRecordInput
还添加了地址而不是变量
recInput.SetRecord(&rec)
res, err1 := svc.PutRecord(&recInput)
而且有效。
关于amazon-web-services - AWS Firehose 和 Go 问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48331054/