Является ли Appsync / GraphQL хорошим решением для отображения в реальном времени сокращенных данных временных рядов на основе S3?
У меня есть файлы JSON, содержащие образцы данных временных рядов, которые загружаются в S3. У меня есть клиент React с компонентом, который должен отображать актуальное статистическое среднее значение выборки данных за последние x минут.
В идеале обновления должны запускаться загрузкой S3, а не браузером, который должен опрашивать веб-службу. Веб-сокеты и события, отправленные сервером, не подходят. Могу ли я практически использовать подписки AWS Appsync для предоставления данных в реальном времени с учетом этих требований?
Я не против использования промежуточной базы данных, если это необходимо. Я предполагаю, что это будет полезно для этапа запроса данных для временного диапазона для вычисления среднего, и я предполагаю, что я бы запустил Lambda с S3 и использовал его для извлечения данных объекта S3 в БД.
Amazon объявила о добавлении Локальные резольверы в феврале.
For example, a Lambda function could invoke GraphQL mutations to AWS AppSync in response to some event that takes place, such as processing data that’s uploaded to an S3 bucket
Это звучит многообещающе, за исключением того, что я не могу найти никаких примеров с участием локальных преобразователей и Lambda / S3. Единственная документация, которую я смог найти, - это здесь.
Обновлено:
Прочитав GraphQL, я узнал об API и, похоже, смогу использовать HTTP-клиент в лямбда-выражении для мутаций. Пробовал это с помощью curl, и это сработало:
curl -X POST \
https://censored.appsync-api.us-east-1.amazonaws.com/graphql \
-H 'Content-Type: application/json' \
-H 'x-api-key: censored' \
-d '{"query": "mutation CreateEvent {createEvent(name: \"testName\", when: \"Now\", where: \"here\", description: \"testDescription\") {name when where description}}"}'
С этим, как я полагаю, теперь я могу вызвать мутацию «addIntervalData» через Lambda, чтобы добавить содержимое каждого объекта S3 в базу данных и использовать лямбда-преобразователь для реализации «getAverage» и выполнения вычисления усреднения. Кажется, хорошее направление?
Ответы 1
Звучит возможно - вам нужно иметь функцию Lambda, которая выполняет мутацию GraphQL для AppSync, с этой мутацией с помощью директивы @aws_subscribe() для уведомления клиентов, которые подписались. Затем, чтобы вызвать эту лямбда-функцию, вы должны использовать источник события S3 для ее вызова. Вот руководство для этого: https://docs.aws.amazon.com/lambda/latest/dg/with-s3.html
@davegravy - это просто стандартная мутация GraphQL в NodeJS (или другом языке, если у вас есть клиент GraphQL), как и в любом другом клиенте. Таким образом, событие S3 вызовет лямбду, а лямбда произведет мутацию. Одна из возможностей может заключаться в использовании категории API AWS Amplify для мутации: aws.github.io/aws-amplify/media/api_guide
Вторая часть хороша, но как мне «иметь лямбда-функцию, которая меняет GraphQL на AppSync»? Единственный учебник, который я могу найти, находится здесь: docs.aws.amazon.com/appsync/latest/devguide/… ... но он предназначен для вызова из AppSync с функцией обратного вызова, которая выполняет фактическую мутацию. Если вызывающим является событие S3, этот обратный вызов не будет предоставлен.