lambda

Author: jcardus

cloudwatch-logs.mjs

@@ -5,7 +5,7 @@ import rabbit from './rabbit.js'
 let counter = 0
 const lines = []
 
-const regExp = /"fixTime":"(2025-09-22T07[^"]*)"/
+const regExp = /"fixTime":"(2025-09-22T17[^"]*)"/
 async function processLines () {
   for (const jsonStr of lines) {
     try {

rabbit.js

@@ -1,6 +1,6 @@
 const amqplib = require('amqplib')
 let _connection = null
-let _channel = getChannel('eb-node-express-2')
+let _channel = getChannel('logs-processor')
   .catch(e => console.error('ERROR INIT _channel', e.message))
 createQueues()
   .catch(e => console.error('ERROR INIT createQueues', e.message))