Как ввести данные в AWS Kinesis из облака частиц JSON веб-хук

Question

Есть ли у кого-нибудь опыт или идея отправить JSON данные для загрузки данных в AWS Kinesis? Я сейчас использую Ubidots для визуализации данных, но теперь я хочу использовать AWS QuickSights для их анализа и визуализации. Вот как выглядит веб-хук:

{
  "Alerts": "{{Alerts}}",
  "Resets": "{{Resets}}",
  "Battery": "{{Battery}}",
  "Distance": "{{Distance}}",
  "Temperature": "{{Temperature}}"
}

Я хочу конечную точку API, через которую я могу отправлять данные в облако.

Необходимо ли отправлять данные в AWS IoT Core и затем отправлять их оттуда в kinesis, или я могу напрямую отправить их из Webhook в Kinesis. Когда у меня есть данные в Kinesis, я могу загрузить их на панель QuickSights. Спасибо, Ханнан

Answer 1

Вот пример использования API-шлюза. Конечная точка шлюза API запускает лямбда-функцию , которая отправляет полезную нагрузку в DynamoDB, но это может быть поток Kinesis. Если вы хотите обойти функцию Lambda, , вы также можете настроить API-шлюз в качестве прокси для Kinesis напрямую .

{
  "event": "sendSleep",
  "url": "https://[yourendpoint].execute-api.us-east-1.amazonaws.com/prod/ParticleSleepV1",
  "requestType": "Post",
  "headers": {
        "x-api-key" : "[yourapikey]"
   },
   "json": {
        "name": "{{SPARK_EVENT_NAME}}",
        "data": "{{SPARK_EVENT_VALUE}}",
        "source": "{{SPARK_CORE_ID}}",
        "published_at": "{{SPARK_PUBLISHED_AT}}"
    },
  "mydevices": true,
  "noDefaults": true
}