1

所以我一直在研究 Promises 和 Waiters,我想知道是否有办法启动转录作业,同时提供回调,所以它会打勾(定期自行检查)直到转录的结果是 COMPLETED, 然后使用回调获取带有转录的 json 并将结果写入 db. 所以我所要做的就是开始工作并提供回调,服务员会定期阻塞线程并检查状态,允许我在两者之间抛出其他请求,而不是用while循环来做这一切。

我尝试了此处提供的示例,但它只是使用该wait()方法并阻塞线程,直到它得到结果。

甚至可以使用转录服务吗?非常感谢一个关于如何做到这一点的小代码示例!

4

1 回答 1

2

我通过执行以下操作从 AWS Transcribe 获得了回调响应:

我使用 PHP SDK 创建了一个转录作业:

use Aws\TranscribeService\TranscribeServiceClient;
...

$transcriber = new TranscribeServiceClient([<config>]);
$job = $transcriber->startTranscriptionJob([<config>, 'TranscriptionJobName' => 'unique-job-name']);

接下来,我登录 AWS 控制台并转到 AWS Lambda。在 Lambda 中,我使用 Node.js 8.10 运行时创建了一个函数:

var https = require('https');

exports.handler = function(event, context) {

    var body='';

    // the post options
    var optionspost = {
        host: 'example.com',
        path: '/transcriptions/callback',
        method: 'POST',
        headers: {
            'Content-Type': 'application/json',
        }
    };

    var reqPost = https.request(optionspost, function(res) {
        res.on('data', function (chunk) {
            body += chunk;
        });

        context.succeed(body);
   });

   reqPost.write(JSON.stringify(event));
   reqPost.end();
};

这会发送一个 POST 请求https://<host><path>,并将event数据作为正文

接下来进入 AWS Cloudwatch 并创建一个rule Events->rules. 在Event Source - Service Name选择Transcribe和配置您的选项下(Event Type -> Transcribe Job State Change, Specific Status -> Completed)。在Targets选择下Lambda Function,然后选择您的function

Lambda Function这将在完成后触发对您的呼叫Transcribe Job。发布到您的服务器的Lambda Function帖子,其中包含转录作业的详细信息,包括Job Name: unique-job-name.

此时,您可以返回Cloudwatch并:

  • 选择您的Rule并单击show metrics for this rule
  • 选择Logs查看您的任何日志记录信息Lambda Function
于 2019-02-14T20:21:25.400 回答