如何订阅过滤器?

订阅是否有一种方法可以接收输入过滤器作为类似于查询和变异的参数?

样本突变反应

{
  taskId: "personal-<uuid>",
  name: "Personal Task 1",
  ...
}

基本上,我只想有一个订阅来检查所有的任务更新 taskId beginsWith String “个人” .

架构

input TableStringFilterInput {
  ne: String
  eq: String
  le: String
  lt: String
  ge: String
  gt: String
  contains: String
  notContains: String
  between: [String]
  beginsWith: String
}

input TaskInput {
  taskId: ID!
  ...
}

input TaskFilterInput {
  taskId: TableStringFilterInput
}

mutation updateTask(task: TaskInput) :  Task
subscription onTaskUpdated(filter: TaskFilterInput) : Task
@aws_subscribe(mutations, ["updateTask"])

使用Appsync的查询控制台测试订阅

subscription TaskUpdated {
  onTaskUpdated(filter: {
    taskId : { beginsWith: "personal" },
  }) {
    taskId
    name
  }
}