Я пытаюсь использовать новый API потоковой транскрипции от Go 1.11.В настоящее время Amazon предоставляет только Java SDK, поэтому я пробую низкоуровневый способ.
Единственный релевантный документ - это здесь , но он не показывает конечную точку.Я обнаружил в Java-примере , что это https://transcribestreaming.<region>.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».
Есть идеи, что я делаю не так?Кто-то успешно использовал новый API потоковой транскрипции без Java SDK?
РЕДАКТИРОВАТЬ (11 марта 2019 г.):
Я протестировал это снова, и теперь это не времявне, но немедленно возвращает 200 OK ответ.В теле ответа есть «исключение»: {"Output":{"__type":"com.amazon.coral.service#SerializationException"},"Version":"1.0"}
Я попытался открыть поток HTTP2 с io.Pipe (как в коде выше), а также с телом JSON, описанным в документации:
{
"AudioStream": {
"AudioEvent": {
"AudioChunk": ""
}
}
}
Результат был таким же.
РЕДАКТИРОВАТЬ (13 марта 2019 г.):
Как упомянуто @gpeng, удаление content-typeиз заголовков исправим SerializationException.Но затем возникает исключение IAM, и необходимо добавить разрешение transcription:StartStreamTranscription вашему пользователю IAM.Это, однако, нигде в консоли AWS IAM и должно быть добавлено вручную в качестве настраиваемого разрешения JSON: /
Здесь также есть новый / другой документ документации , который показывает неверные host иновый content-type (не используйте этот content-type, запрос вернет 404 с ним).
После удаления content-type и добавления нового разрешения, теперь я получаю исключение {"Message":"A complete signal was sent without the preceding empty frame."}.Также пишу в трубу навсегда, поэтому я снова застрял.Сообщения, описанные в новой документации, отличаются от старых, теперь, наконец, двоичные, но я их не понимаю.Любые идеи, как отправить такие сообщения HTTP2 в Go?
РЕДАКТИРОВАТЬ (Match 15, 2019): *
Если вы получаете ошибку HTTP 403 о несоответствии сигнатур, затем выполнитене устанавливать заголовки HTTP transfer-encoding и x-amz-content-sha256.Когда я их устанавливаю, подписываю запрос подписчиком AWS SDK V4, затем я получаю HTTP 403 The request signature we calculated does not match the signature you provided.