当前位置：首页 > 文章列表 > Golang > Go问答 > Amazon Transcribe 流式 API 的非 SDK 版本

Amazon Transcribe 流式 API 的非 SDK 版本

来源：stackoverflow 2024-03-09 09:54:27 0浏览收藏

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《Amazon Transcribe 流式 API 的非 SDK 版本》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

问题内容

我正在尝试使用 go 1.11 中的 amazon 新流转录 api。目前亚马逊只提供java sdk，所以我正在尝试低级方法。

唯一相关的文档在这里，但它没有显示端点。我在java示例中发现它是https://transcribestreaming..amazonaws.com，我正在尝试爱尔兰地区，即https://transcribestreaming.eu-west-1.amazonaws.com。这是我打开 http/2 双向流的代码：

import (
    "crypto/tls"
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/aws/external"
    "github.com/aws/aws-sdk-go-v2/aws/signer/v4"
    "golang.org/x/net/http2"
    "io"
    "io/ioutil"
    "log"
    "net/http"
    "os"
    "time"
)

const (
    headerkeylanguagecode   = "x-amzn-transcribe-language-code"  // en-us
    headerkeymediaencoding  = "x-amzn-transcribe-media-encoding" // pcm only
    headerkeysamplerate     = "x-amzn-transcribe-sample-rate"    // 8000, 16000 ... 48000
    headerkeysessionid      = "x-amzn-transcribe-session-id"     // for retrying a session. pattern: [a-fa-f0-9]{8}-[a-fa-f0-9]{4}-[a-fa-f0-9]{4}-[a-fa-f0-9]{4}-[a-fa-f0-9]{12}
    headerkeyvocabularyname = "x-amzn-transcribe-vocabulary-name"
    headerkeyrequestid = "x-amzn-request-id"
)

...

region := "eu-west-1"

cfg, err := external.loaddefaultawsconfig(aws.config{
    region: region,
})
if err != nil {
    log.printf("could not load default aws config: %v", err)
    return
}

signer := v4.newsigner(cfg.credentials)

transport := &http2.transport{
    tlsclientconfig: &tls.config{
        // allow insecure just for debugging
        insecureskipverify: true,
    },
}
client := &http.client{
    transport: transport,
}

signtime := time.now()

header := http.header{}
header.set(headerkeylanguagecode, "en-us")
header.set(headerkeymediaencoding, "pcm")
header.set(headerkeysamplerate, "16000")
header.set("content-type", "application/json")

// bi-directional streaming via a pipe.
pr, pw := io.pipe()

req, err := http.newrequest(http.methodpost, "https://transcribestreaming.eu-west-1.amazonaws.com/stream-transcription", ioutil.nopcloser(pr))
if err != nil {
    log.printf("err: %+v", err)
    return
}
req.header = header

_, err = signer.sign(req, nil, "transcribe", region, signtime)
if err != nil {
    log.printf("problem signing headers: %+v", err)
    return
}

// this freezes and ends after 5 minutes with "unexpected eof".
res, err := client.do(req)
...

问题是执行请求 (client.do(req)) 冻结五分钟，然后以“意外的 eof”错误结束。

你知道我做错了什么吗？有人在没有 java sdk 的情况下成功使用了新的流转录 api 吗？

编辑（2019 年 3 月 11 日）：

我再次测试了这一点，现在它没有超时，而是立即返回 200 ok 响应。但响应正文中有一个“异常”： {"output":{"__type":"com.amazon.coral.service#serializationexception"},"version":"1.0"}

我尝试使用 io.pipe （如上面的代码）以及文档中描述的 json 正文打开 http2 流：

{
    "AudioStream": { 
        "AudioEvent": { 
            "AudioChunk": ""
        }
    }
}

结果是一样的。

编辑（2019 年 3 月 13 日）：

正如 @gpeng 所提到的，从标头中删除 content-type 将修复 serializationexception。但随后出现 iam 异常，需要向您的 iam 用户添加 transcription:startstreamtranscription 权限。但这在 aws iam 控制台中不存在，必须作为自定义 json 权限手动添加：/

这里还有一个新的/另一个文档文档，其中显示了不正确的 host 和新的 content-type （不要使用该 content-type，请求将返回 404）。

删除 content-type 并添加新权限后，现在我收到异常 {"message":"已发送完整信号，但没有前面的空帧。"}。还永远写入管道块，所以我再次陷入困境。新文档中描述的消息与旧文档中描述的消息不同，现在终于是二进制的，但我不明白它们。有什么想法如何在 go 中发送此类 http2 消息吗？

编辑（2019 年第 15 场比赛）：*

如果您收到有关签名不匹配的 http 403 错误，请不要设置 transfer-encoding 和 x-amz-content-sha256 http 标头。当我设置它们时，使用 aws sdk 的 v4 签名者对请求进行签名，然后我收到 http 403 我们计算的请求签名与您提供的签名不匹配。