node.js - AWS AppSync : How to listen to change from DynamoDB (not by mutation)

Question

我从 Amplify Cli 为我的 Angular 项目创建 AppSync API。

网站可以订阅OnChangeListner，其中DynamoDB通过突变进行更新。它有效。

async ngOnInit() {

   this.api.OnUpdateTableListener.subscribe({
      next: resp => {
        console.log("update !!!");
        console.log("update: " + JSON.stringify(resp));
        let update = resp.value.data.onUpdateTable;
        this.items = this.items.map(function(a) {
          return a.id === update.id ? update : a;
        });

      }
    });
}


async update(selectedItem) {
    const update = {
      id: selectedItem.id,
      status: !selectedItem.status
    };
    await this.api.UpdateTable(update);
  }

但是，我注意到，如果我手动更新 DynamoDB，则订阅根本不起作用。

有关如何更新 DynamoDB(不是通过突变)和 AppSync 订阅的任何建议仍然有效。

Answer 1

AppSync 只能通过订阅传递通过突变传递给它的消息。如果对 DynamoDB 表进行更改，确保始终通过订阅传递消息的一种方法是将 Kinesis 流添加到表中，该流将在表发生更改时发出事件。然后，您可以让 Lambda 函数订阅此 Kinesis 流，并对 AppSync 进行 Mutation 调用，以将修改后的数据通过订阅发送到连接的客户端。见图: