在 MoleculerJS 中构建上下文对象

Question

我无法理解 MoleculerJS 的基本概念。我有一个在收到 SQS 消息时调用的方法。

const msg = await receiveOneMessageFromSQS();
/*
example structure of msg
{
  userId: 1
}
*/

现在我需要调用另一个服务并将“msg”作为服务参数发送。

await ctx.call(`AnothorService.AnotherAction`, msg);

我将需要 Context 对象，以便调用另一个服务操作（这是否正确？？）。但是如您所见，我在接收来自 SQS 的消息的范围内没有上下文对象。

问题

我是否遵循了正确的方法来实现我想做的事情？如果是这样，我如何构造一个上下文对象？

完整代码（如果需要）

@Service({
    name: 'serviceName',
})
export class ServiceNameService extends MoleculerService {
    sqsClient: SQSClient;

    constructor(
        broker: Moleculer.ServiceBroker,
        schema: Moleculer.ServiceSchema<Moleculer.ServiceSettingSchema>,
    ) {
        super(broker, schema);
        this.sqsClient = new SQSClient({ region: "eu-central-1" });
    }
public async started() {
        const readFromSQS = async () => {
            const msg = await receiveOneMessageFromSQS();
            if (msg) {
              // PROBLEM HERE. No ctx here.
              await ctx.call(`AnothorService.AnotherAction`, msg);
            }
        };
        setInterval(async () => {
            await readFromSQS();
        }, 20000);
        return await connectionInstance();
    }
}

Answer 1

lifecycle methods 没有任何输入参数，这意味着默认情况下您没有上下文对象。

但是，您可以使用 await this.broker.call("service.name", {data}) 并调用其他服务。

在 MoleculerJS 中构建上下文对象

Constructing Context Object in MoleculerJS

node.js

moleculer