move lambda handler

Author: jcardus

.github/workflows/lambda.yml

@@ -23,7 +23,7 @@ jobs:
         run: |
           aws lambda update-function-configuration \
             --function-name recover-positions-from-log \
-            --handler cloudwatch-logs.lambda
+            --handler lambda.lambda
           
           aws lambda update-function-code \
             --function-name recover-positions-from-log \

cloudwatch-logs.mjs

@@ -1,8 +1,6 @@
 import fs from 'fs'
 import readline from 'readline'
 import rabbit from './rabbit.js'
-import zlib from 'zlib'
-import sqs from './sqs.js'
 
 let counter = 0
 const lines = []
@@ -22,22 +20,6 @@ async function processLines () {
   }
 }
 
-export async function lambda (e) {
-  const payload = Buffer.from(e.awslogs.data, 'base64')
-  const json = JSON.parse(zlib.gunzipSync(payload).toString('utf8'))
-
-  for (const { message } of json.logEvents) {
-    console.log('Message:', message)
-    const idx = message.indexOf('{')
-    if (idx === -1) continue // skip if no JSON
-    const jsonStr = message.slice(idx)
-    console.log(jsonStr)
-    await sqs.sendMessage(message, 'https://sqs.us-east-1.amazonaws.com/925447205804/rabbit-dlq')
-    //    await rabbit.send(jsonStr, 'E', 'P', 'eb-node-express-positions')
-  }
-  setTimeout(rabbit.close, 10000)
-}
-
 export function main () {
   console.log('Starting CloudWatch logs processing...')
 

lambda.mjs

@@ -0,0 +1,16 @@
+import zlib from 'zlib'
+import sqs from './sqs.js'
+
+export async function lambda (e) {
+  const payload = Buffer.from(e.awslogs.data, 'base64')
+  const json = JSON.parse(zlib.gunzipSync(payload).toString('utf8'))
+
+  for (const { message } of json.logEvents) {
+    console.log('Message:', message)
+    const idx = message.indexOf('{')
+    if (idx === -1) continue // skip if no JSON
+    const jsonStr = message.slice(idx)
+    console.log(jsonStr)
+    await sqs.sendMessage(message, 'https://sqs.us-east-1.amazonaws.com/925447205804/rabbit-dlq')
+  }
+}