Подписка на события AWS AppSync в зависимости от местоположения

Question

Я понимаю, как выполнять геопространственные запросы через AppSync чтобы найти события в пределах расстояния от GPS-координаты, добавив решатель, связанный с ElasticSesarch, как описано здесь.

Однако что, если я хочу, чтобы мой клиент подписывался на новые события, создаваемые в этом диапазоне расстояний?

1. пользователь подписывается на местоположение
2. если событие создается рядом с этим местом, уведомить пользователя

Я знаю, что могу прикрепить распознаватель к типам подписки, но кажется, что это заставляет вас предоставлять источник данных, когда я просто хочу отфильтровать подписки, проверяя расстояние между координатами GPS.

Answer 1

Это отличный вопрос, и я думаю, что есть несколько способов решить это. Сложность в том, что вам нужно будет найти способ задать вопрос: "Какие подписки заинтересованы в событии в этом месте". Вот один из возможных путей продвижения вперед.

Далее предполагается, что эти части схемы:

// Whatever custom object has a location 
type Post {
  id: ID!
  title: String
  location: Location
}
input PublishPostInput {
  id: ID!
  title: String
  location: Location
  subscriptionID: ID
}
type PublishPostOutput {
  id: ID!
  title: String
  location: Location
  subscriptionID: ID
}

type Location {
  lat: Float,
  lon: Float
}
input LocationInput {
  lat: Float,
  lon: Float
}

# A custom type to hold custom tracked subscription information
# for location discover
type OpenSubscription {
  subscriptionID: ID!
  location: Location
  timestamp: String!
}
type OpenSubscriptionConnection {
  items: [OpenSubscription]
  nextToken: String
}

type Query {
  # Query elasticsearch index for relevant subscriptions
  openSubscriptionsNear(location: LocationInput, distance: String): OpenSubscriptionConnection
}
type Mutation {
  # This mutation uses a local resolver (e.g. a resolver with a None data source) and simply returns the input as is.
  publishPostToSubscription(input: PublishPostInput): PublishPostOutput
}
type Subscription {
  # Anytime someone passes an object with the same subscriptionID to the "publishPostToSubscription" mutation field, get updated.
  listenToSubscription(subscriptionID: ID!): PublishPostOutput
    @aws_subscribe(mutations:["publishPostToSubscription"])
}

Предполагая, что вы используете DynamoDB в качестве основного источника правды, настройте поток DynamoDB, который вызывает лямбда-функцию "PublishIfInRange". Эта функция "PublishIfInRange" будет выглядеть примерно так

// event - { location: { lat, lon }, id, title, ... }
function lambdaHandler(event) {

  const relevantSubscriptions = await callGraphql(`
    query GetSubscriptions($location: LocationInput) {
      openSubscriptionsNear(location:$location, distance: "10 miles") {
        subscriptionID
      }
    }
  `, { variables: { location: event.location }})

  for (const subscription of relevantSubscriptions) {
    callGraphql(`
      mutation PublishToSubscription($subID: ID!, $obj: PublishPostInput) {
        publishPostToSubscription(input: $obj) {
          id
          title
          location { lat lon }
          subscriptionID
        }
      }
    `, { variables: { input: { ...subscription, ...event }}})
  }
}

Вам нужно будет вести реестр подписок, проиндексированных по местоположению. Один из способов сделать это состоит в том, чтобы ваше клиентское приложение вызывало мутацию, которая создает объект подписки с местоположением и subscriptionID (например, mutation { makeSubscription(loc: $loc) { ... } } при условии, что вы используете $util.autoId() для генерации subscriptionID в распознавателе). После того, как у вас есть идентификатор подписки, вы можете сделать вызов подписки через graphql и передать в качестве аргумента идентификатор подписки (например,subscription { listenToSubscription(subscriptionID: "my-id") { id title location { lat lon } } }). Когда вы делаете вышеуказанный вызов по подписке, AppSync создает тему и уполномочивает текущего пользователя подписаться на эту тему. Тема уникальна для вызываемого поля подписки и набора аргументов, передаваемых в поле подписки. Другими словами, тема получает только объекты

Теперь, когда объект создается, запись передается в лямбда-функцию через потоки DynamoDB. Лямбда-функция запрашивает эластичный поиск для всех открытых подписок рядом с этим объектом, а затем публикует запись для каждой из этих открытых подписок.

Я считаю, что это должно дать вам достаточно далеко, но если у вас миллионы пользователей в тесноте, вы, скорее всего, столкнетесь с проблемами масштабирования. Надеюсь это поможет