时间戳

首页 > 解决方案 > `appsync` 是否支持订阅中的 `withFilter`？

amazon-web-services - `appsync` 是否支持订阅中的 `withFilter`？

问题描述

我有一个用 nodejs 编写的 graphql，带有Apollo Server. 下面是subscription代码。如您所见，它使用withFilter了两个函数参数。

在第一个函数中，它接受参数和调用pubSub.subscribe('TRANSACTION_REQUEST' + args.transactionId)来订阅主题。请注意，主题名称是一个动态名称，其中包括来自用户请求的事务 ID。

在第二个函数中，它过滤掉不匹配的 userId。

所以我的问题是如何在Appsync.

const resolvers = {
...
  Subscription: {
    requestTransaction: {
      subscribe: withFilter(
        (rootValue: any, args: any, context: any, info: any) => {
          console.log('req txn with filter args', args);
          return pubSub.subscribe('TRANSACTION_REQUEST' + args.transactionId)(
            rootValue,
            args,
            context,
            info,
          );
        },
        (transactionResponse: any, transactionRequest: any) => {
          console.log('with filter transaction');
          console.log('subscribe:', transactionResponse, transactionRequest);
          return (
            transactionResponse.userId ===
            transactionRequest.transactionInput.userId
          );
        },
      ),
    },
  },
...

标签： amazon-web-servicesgraphqlaws-appsync

解决方案

在 AppSync 中，您将无法在增量过滤订阅事件时进行记录，但您可以让用户提供要过滤的属性，以便生成的订阅事件相同。

这Event只是您的突变返回的对象的类型：

type Subscription {
    subscribeTransaction(topic: String userId: String): Event
            @aws_subscribe(mutations: ["fooMutation"])
}

开始订阅：

subscription onTransact {
    subscribeTransaction(topic: "TRANSACTION_REQUEST" + args.transactionId userId: args.userId){
        id
        foo
        bar
    }
}

笔记：

  • 这个名字onTransact是任意的
  • 假设transactionId并userId在里面通过args
  • id,foo并且bar只有当突变也请求这些属性时才会返回

推荐阅读