elixir - 如何告诉苦艾酒它应该发出查询以发送未完成订阅的更新？

Question

我正在运行查询后端的 Absinthe GraphQL 服务器，但也有来自外部的事件（通过 AMQP），表明发生了更新（其中一些不包括更新的记录信息）。

我可以处理包含新记录的事件Absinthe.Subscription.publish。

但是如何处理更新记录不存在的情况呢？

换句话说，我想触发 Absinthe 发出查询，并将结果作为现有订阅的结果发送到 GraphQL 客户端。