我的目标是使用 AWS Kinesis API 创建一个具有特定名称的 Kinesis 流（如果它尚不存在），然后写入它，无论它是否首先存在。
这是我到目前为止想出的。尝试创建流。如果它失败并显示代码 400 并返回一个请求 ID，那么该流可能已经存在。然后写入流以确保它在那里。在围棋中：
k := kinesis.New(session.New())
_, err := k.CreateStream(&kinesis.CreateStreamInput{
ShardCount: aws.Int64(2),
StreamName: aws.String("stream"),
})
if err != nil {
if reqerr, ok := err.(awserr.RequestFailure); ok {
if reqerr.RequestID() == "" {
log.Fatal("request was not delivered as it has no ID",
reqerr.Code(),
reqerr.Message(),
)
}
if reqerr.StatusCode() != 400 {
log.Fatal("unexpected status code", reqerr.StatusCode())
}
} else {
log.Fatal(err)
}
}
// Code 400 + requestID does not necessarily mean that the stream exists
// So write to the stream to confirm it exists
_, err = k.PutRecord(&kinesis.PutRecordInput{
Data: []byte("Hello Kinesis"),
PartitionKey: aws.String("partitionkey"),
StreamName: aws.String("stream"),
})
if err != nil {
log.Fatal(err)
}
上面的方法似乎令人费解，更重要的是，我认为它不能有效地匹配我期望的确切错误。对错误消息进行字符串比较似乎也是一个糟糕的选择，因为这很容易改变。
我想知道是否有更可靠和直接的方法来实现这一目标？列出所有可用的流进行搜索是一件痛苦的事情，因为它是一种线性搜索，并且涉及多个具有新值 的请求ExclusiveStartStreamName。
慕娘9325324
相关分类