Skip to content

Instantly share code, notes, and snippets.

@cassc
Created May 29, 2022 08:19
Show Gist options
  • Save cassc/74340848e5cc35fd21a81ef8a5c3e974 to your computer and use it in GitHub Desktop.
Save cassc/74340848e5cc35fd21a81ef8a5c3e974 to your computer and use it in GitHub Desktop.
aws sqs sample event from sns topic.json
{
"Records": [
{
"messageId": "1eaa56db-c31c-491f-84ea-e58f4fe20e4f",
"receiptHandle": "AQEBN2NLRnTcSX0zuKkkHsSnpxcwglSRP5uiv3DRlteaPStK9FBqc0UZeaunyq3LuLyJC4gyJrKmDG6zESio1S0ErXhWO55xp2+zSIqEAdV+WkIaREutcu/oHk2Q+KA3WE2LuJ0T4tWevOVvyf6tL8QUur02eYN+7xYapeTcKifaed2m/BJFGPUEDo5kzeMQTqnnqqCWtvssFpVBvDFeM+NN36tokIYLhWwuESqMqf3KM1IH58HfX3F2XXxdAwkAgTHFjtVqP94ntTzYiNA6HlvmY3TShR2TqNodIan5elRsv89DWqP0KQJXszRPtsPEog/eXnJApoVxpEopJoE/euU/ItXi7EnOMRWIV2AZ1CU8ctyYLjtsBS1vNhzCtkrdnLwDJp6y8Hte2JA1c4zU/XTfpw==",
"body": "{\n \"Type\" : \"Notification\",\n \"MessageId\" : \"6d5f16a0-f45a-5644-9320-4dadd2a4d37f\",\n \"TopicArn\" : \"arn:aws:sns:eu-west-1:488682066271:vod-v2-SnsTopic-QA50ZMXLQDIY\",\n \"Subject\" : \"Workflow Status:: Complete:: ba681a1a-b254-4870-9f22-1dbb09940d2d\",\n \"Message\" : \"{\\n \\\"encodeJobId\\\": \\\"1653810291539-pao7i2\\\",\\n \\\"frameCapture\\\": true,\\n \\\"acceleratedTranscoding\\\": \\\"PREFERRED\\\",\\n \\\"workflowTrigger\\\": \\\"Video\\\",\\n \\\"frameCaptureWidth\\\": 1280,\\n \\\"cloudFront\\\": \\\"d2912fs2wo4oqp.cloudfront.net\\\",\\n \\\"archiveSource\\\": \\\"DISABLED\\\",\\n \\\"enableSqs\\\": true,\\n \\\"srcBucket\\\": \\\"vod-v2-source-2aa8d38ok2mp\\\",\\n \\\"inputRotate\\\": \\\"DEGREE_0\\\",\\n \\\"srcWidth\\\": 640,\\n \\\"destBucket\\\": \\\"obr-vod-destination-vpx8y5wsew25\\\",\\n \\\"workflowStatus\\\": \\\"Complete\\\",\\n \\\"workflowName\\\": \\\"vod-v2\\\",\\n \\\"encodingProfile\\\": 720,\\n \\\"isCustomTemplate\\\": false,\\n \\\"startTime\\\": \\\"2022-05-29T07:44:41.503Z\\\",\\n \\\"enableMediaPackage\\\": true,\\n \\\"frameCaptureHeight\\\": 720,\\n \\\"jobTemplate\\\": \\\"vod-v2_Ott_720p_Avc_Aac_16x9_mvod\\\",\\n \\\"enableSns\\\": true,\\n \\\"srcVideo\\\": \\\"d38a3e53-729c-4005-848f-d12c06754c3e.mp4\\\",\\n \\\"srcHeight\\\": 480,\\n \\\"endTime\\\": \\\"2022-05-29T07:46:02.161Z\\\",\\n \\\"egressEndpoints\\\": {\\n \\\"HLS\\\": \\\"https://d2912fs2wo4oqp.cloudfront.net/out/v1/506ba5b4127e47ef990d2f5d4b1605dd/59e14ec4435a4f6ba29f8a21036c24e4/e281aa23e50f4113aebd0b591b45a01a/index.m3u8\\\",\\n \\\"DASH\\\": \\\"https://d2912fs2wo4oqp.cloudfront.net/out/v1/506ba5b4127e47ef990d2f5d4b1605dd/56b85f180d5f463893c290e4fce2af13/5486d17b4baa46a1a1e967fa3dadaf47/index.mpd\\\",\\n \\\"CMAF\\\": \\\"https://d2912fs2wo4oqp.cloudfront.net/out/v1/506ba5b4127e47ef990d2f5d4b1605dd/2d8903a71cbb47afb83d6c3cdef85a16/e352240f016a46b085e14b9d76462e43/index.m3u8\\\",\\n \\\"MSS\\\": \\\"https://d2912fs2wo4oqp.cloudfront.net/out/v1/506ba5b4127e47ef990d2f5d4b1605dd/28aabc0f807d4829b1fc993c13541e1b/bca72854e5ec4eddba90344660e6c984/index.ism/Manifest\\\"\\n },\\n \\\"guid\\\": \\\"ba681a1a-b254-4870-9f22-1dbb09940d2d\\\"\\n}\",\n \"Timestamp\" : \"2022-05-29T07:46:06.323Z\",\n \"SignatureVersion\" : \"1\",\n \"Signature\" : \"Shsn7Y3AuNN7QUFAhw5+UHFUIyQixfyX9at+qXg1MgkjblANszWZnQqVTOG+xNTEjwlcxIElDPcjR3qEnpz40/xrP5S/6EbgKVRfNML+5JhAXD83UgA3Xloid7fzL1gAZnGNJoNN+Z3oVANEo21wr/rmS0gP4OuVaPi4SW+LGKHH2WutTamzQYQxj1RkQP0W37CTlcNLO5I7+fOCdnS6LB0CsKryMz+HO2HR4rfuVV9xp5KhwVNNJw1vCHQp1+u/QHoj9cSH52WWnIMdwyllG+KVFm/d2I4GWOwgkBv+nOHp0+H2VHua//zLPoSeSCTokZJdbpVjOg+wmayEjB+yxA==\",\n \"SigningCertURL\" : \"https://sns.eu-west-1.amazonaws.com/SimpleNotificationService-7ff5318490ec183fbaddaa2a969abfda.pem\",\n \"UnsubscribeURL\" : \"https://sns.eu-west-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-west-1:488682066271:vod-v2-SnsTopic-QA50ZMXLQDIY:5b349544-e04d-452a-9fbc-8d9727139eda\"\n}",
"attributes": {
"ApproximateReceiveCount": "1",
"SentTimestamp": "1653810366362",
"SenderId": "AIDAISMY7JYY5F7RTT6AO",
"ApproximateFirstReceiveTimestamp": "1653810366364"
},
"messageAttributes": {},
"md5OfBody": "ad40b8548fdf1f4a97fe7e0840377ff0",
"eventSource": "aws:sqs",
"eventSourceARN": "arn:aws:sqs:eu-west-1:488682066271:AutoNodeCreationStackSQS",
"awsRegion": "eu-west-1"
}
]
}
@cassc
Copy link
Author

cassc commented May 29, 2022

  const record = event.Records[0]
  let msg
  if (record.eventSource == 'aws:sqs'){
    const sqsMsg = JSON.parse(event.body)
    msg = JSON.parse(sqsMsg.Message)
  }else{
    msg = JSON.parse(record.Sns.Message) 
  }

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment