Update montecarlo_ec2

montecarlo_ec2

@@ -31,9 +31,7 @@ def calculate_mean_std(close_prices):
     return mean_value, std_value
 
 def process_stock_data(event):
-    """
-    Processing the stock data to identify signals and perform Monte Carlo simulation for each signal.
-    """
+    logging.debug(f"Received event: {event}")
     stock_data = event.get('stock_data')
     h = int(event.get('h'))
     d = int(event.get('d'))
@@ -43,11 +41,14 @@ def process_stock_data(event):
     var99_list = []
     signal_dates = []
 
+    logging.debug(f"Processing {len(stock_data)} records with h={h}, d={d}, t={t}")
+
     for i in range(h, len(stock_data)):
         if (t == 'buy' and stock_data[i]['Buy'] == 1) or (t == 'sell' and stock_data[i]['Sell'] == 1):
             close_prices = [entry['Close'] for entry in stock_data[i-h:i]]
             
             if len(close_prices) < h:
+                logging.debug(f"Skipping index {i}, insufficient data")
                 continue
             
             mean_value, std_value = calculate_mean_std(close_prices)
@@ -58,13 +59,15 @@ def process_stock_data(event):
             signal_dates.append(stock_data[i]['Date'])
 
     results = {
-       # 'dates': signal_dates,
         'var95': var95_list,
         'var99': var99_list
     }
 
+    logging.debug(f"Generated results: {results}")
+
     return results
 
+
 def main():
     try:
         # check and parsing the incoming JSON payload