Streaming Data Platform

{
  "nodes": [
    { "id":"src1","type":"aws-apigw","label":"Web events","x":40,"y":80 },
    { "id":"src2","type":"aws-lambda","label":"CDC connector","x":40,"y":220 },
    { "id":"src3","type":"server","label":"IoT devices","x":40,"y":360 },
    { "id":"topic1","type":"aws-sns","label":"events.raw","x":260,"y":150 },
    { "id":"topic2","type":"aws-sns","label":"events.enriched","x":540,"y":150,"bold":true },
    { "id":"proc","type":"rounded","label":"Stream processor\n(Flink / Kafka Streams)","x":380,"y":280,"fill":"#fef3c7","bold":true },
    { "id":"sink1","type":"aws-dynamo","label":"State store","x":540,"y":380 },
    { "id":"c1","type":"aws-cloudfront","label":"Real-time dashboard","x":760,"y":40 },
    { "id":"c2","type":"aws-s3","label":"Warehouse","x":760,"y":160 },
    { "id":"c3","type":"aws-lambda","label":"Alerts","x":760,"y":280 }
  ],
  "edges": [
    { "id":"a","source":"src1","target":"topic1","thickness":2 },
    { "id":"b","source":"src2","target":"topic1" },
    { "id":"c","source":"src3","target":"topic1" },
    { "id":"d","source":"topic1","target":"proc" },
    { "id":"e","source":"proc","target":"topic2","thickness":2 },
    { "id":"f","source":"proc","target":"sink1","style":"dashed" },
    { "id":"g","source":"topic2","target":"c1" },
    { "id":"h","source":"topic2","target":"c2" },
    { "id":"i","source":"topic2","target":"c3" }
  ]
}