如何使用 cloudevents sdk-javascript 回复 CloudEvent

问题描述

我想使用 Knative Sequence 来链接几个 ksvc 但失败了。第一步 ksvc 可以触发，其余的不能触发。

在我的 ksvc(Node.js) 中，我使用了 CloudEvent js-sdk。我假设我需要在收到它后返回一个新的 CloudEvent。所以这是我的代码：

app.post('/',(req,res)=>{ 
   const event = HTTP.toEvent({ headers: req.headers,body: req.body });

   // respond as an event
   const responseEventMessage = new CloudEvent({
      source: '/',type: 'event:response',...event
    });
   responseEventMessage.data = {
      hello: 'world'
    };
    res.status(201).json(responseEventMessage);
})

解决方法

我认为应该使用 HTTP.binary() 或 HTTP.structured() 将事件转换为标题和正文。

    const responseEventMessage = new CloudEvent({
        ...receivedEvent,source: '/',type: 'event:response'
    });
    // const message = HTTP.binary(responseEventMessage)
    const message = HTTP.structured(responseEventMessage)
    res.set(message.headers)
    res.send(message.body)

编辑：可能需要设置 body-parser。

const bodyParser = require('body-parser')
app.post("/",bodyParser.json(),(req,res) => {})

另外最好使用 cloneWith() 而不是传播。

    const responseEventMessage = receivedEvent.cloneWith({
        source: '/',type: 'event:response'
    });

您好，很抱歉给您带来麻烦。

我对js sdk不是很熟悉，但是我们这里使用的例子： https://github.com/knative/docs/blob/master/docs/serving/samples/cloudevents/cloudevents-nodejs/index.js#L64

使用 .send() 而不是 .json()

至于配置序列，希望这些示例有助于正确配置序列： https://knative.dev/docs/eventing/flows/sequence/

序列状态是否显示任何错误？

最后，您是否在日志中看到任何错误？根据您安装的组件，这可能会有所不同，但如果您正在运行核心并使用 InMemoryChannel，日志将位于 knative-eventing 命名空间中，并且您会看到 imc-dispatcher-* pods，如果事件构造不正确。

cloudevents knative knative-eventing