2

我正在将Javascript（节点）中的AWS Polly代码从v2转换为v3。

使用AWS Polly v3 synthesizeSpeech()时，如何将返回的转换data.AudioStream为 的实例Buffer？

以下 JavaScript 代码使用v2工作，并返回audio.AudioStream一个实例Buffer：

const { Polly } = require('aws-sdk');

// Create an Polly client
const polly = new Polly({
    signatureVersion: 'v4',
    region: process.env.AWS_DEFAULT_REGION
});

const params = {
    OutputFormat: 'mp3',
    VoiceId: voiceId,
    TextType: 'ssml',
    Text: '<speak><prosody rate="85%">Hello World</prosody></speak>'
};

// ***

return await polly
    .synthesizeSpeech(params)
    .promise()
    .then(data => {
         if (data.AudioStream instanceof Buffer) {
             return data.AudioStream
         } else {
             console.error('AudioStream not instanceof Buffer');
             return null;
         }
     })

以下使用v3synthesizeSpeech()的 JavaScript 代码，其来自contains的响应audio.AudioStream不是 的实例Buffer，而是以 开头IncomingMessage：

const {
    Polly
} = require("@aws-sdk/client-polly");

// Create an Polly client
const polly = new Polly({
    signatureVersion: 'v4',
    region: process.env.AWS_DEFAULT_REGION
});

// ***

const params = {
    OutputFormat: 'mp3',
    VoiceId: voiceId,
    TextType: 'ssml',
    Text: '<speak><prosody rate="85%">Hello World</prosody></speak>'
};

return await polly
    .synthesizeSpeech(params)
    .then(data => {
         if (data.AudioStream instanceof Buffer) {
             return data.AudioStream
         } else {
             console.error('AudioStream not instanceof Buffer');
             return null;
         }
     })

我都使用and尝试了以下v3，结果相同PollyClientSynthesizeSpeechCommand

const {
    PollyClient,
    SynthesizeSpeechCommand
} = require("@aws-sdk/client-polly");

const client = new PollyClient({
    region: process.env.AWS_DEFAULT_REGION
});

// ***

const command = new SynthesizeSpeechCommand({
    OutputFormat: 'mp3',
    Text:'hello world, this is alex',
    VoiceId: 'Kimberly',
    TextType: 'text'
});

return client
    .send(command)
    .then((data) => {
        if (data.AudioStream instanceof Buffer) {
            return data.AudioStream
        } else {
            console.error('AudioStream not instanceof Buffer');
            console.log('data.AudioStream:', data.AudioStream);
            return null;
        }
    })
    .catch((error) => {
        console.error(error);
    });

v3 的内容data.AudioStream是：

IncomingMessage {
  _readableState:
   ReadableState {
     objectMode: false,
     highWaterMark: 16384,
     buffer: BufferList { head: null, tail: null, length: 0 },
     length: 0,
     pipes: null,
     ***

感谢您的阅读，任何反馈表示赞赏。

4

2 回答 2

3

现在是一个 ReadableStream 对象。

   import { Readable } from "stream";
    //...
    if (data.AudioStream instanceof Readable) {
      console.log("Readable");
      data.AudioStream.pipe(fs.createWriteStream("fileName.mp3"));
    } else {
      console.log("no Readable");
    }
    //...

您可以在此处找到有关此更改的详细信息： https ://github.com/aws/aws-sdk-js-v3/issues/1096#issuecomment-620900466

于 2021-03-04T11:26:52.167 回答
1

就我个人而言，我发现使用 async/await 而不是流回调更容易......

import { PollyClient, SynthesizeSpeechCommand, SynthesizeSpeechInput } from "@aws-sdk/client-polly";
import fs from 'fs';

async function go() {
    const client = new PollyClient(yourClientOptions)
    const command = new SynthesizeSpeechCommand(yourCommandOptions)
    try {
        let data = await client.send(command)
        if (!data || !data.AudioStream) throw Error(`bad response`);
        await saveStream(data.AudioStream, "output.mp3")
    }
    catch(err) {
        console.log(err)
    }
}

async function saveStream(fromStream, filename) {
    return new Promise((resolve, reject) => {
        let toStream = fs.createWriteStream(filename)
        toStream.on('finish', resolve);
        toStream.on('error', reject);
        fromStream.pipe(toStream)
    })
}

go()

注意：我使用的是 node14，因此可以import在顶部使用，但您也可以轻松使用require.

于 2021-03-11T14:55:25.770 回答