Method stream_insert

src/environment/alpacaentry/bars.py:197–253

Insert bars data from stream. Args: data: Raw bars data dictionary from Alpaca stream symbol: Symbol name asset_type: Optional asset type (not used for bars, kept for compatibility) Returns: True if successful, Fal

(self, data: Dict, symbol: str, asset_type=None)

        return db_data
    
    async def stream_insert(self, data: Dict, symbol: str, asset_type=None) -> bool:
        """Insert bars data from stream.
        
        Args:
            data: Raw bars data dictionary from Alpaca stream
            symbol: Symbol name
            asset_type: Optional asset type (not used for bars, kept for compatibility)
            
        Returns:
            True if successful, False otherwise
        """
        try:
            # Ensure table exists
            await self.ensure_table_exists(symbol)
            
            # Prepare data for insertion
            db_data = self._prepare_data_for_insert(data, symbol)
            
            # Insert into database
            base_name = self._sanitize_table_name(symbol)
            table_name = f"{base_name}_bars"
            
            insert_request = InsertRequest(
                table_name=table_name,
                data=db_data
            )
            
            # Debug: Log what we're trying to insert
            logger.debug(f"| 🔍 Attempting to insert bars data for {symbol} into {table_name}: {db_data}")
            
            result = await self.database_service.insert_data(insert_request)
            
            if not result.success:
                logger.error(f"| ❌ Failed to insert bars data for {symbol}: {result.message}")
                logger.error(f"| ❌ Insert request: table={table_name}, data={db_data}")
                return False
            
            # Verify insertion by querying the table
            verify_query = f"SELECT COUNT(*) as count FROM {table_name}"
            verify_result = await self.database_service.execute_query(QueryRequest(query=verify_query))
            if verify_result.success:
                count = verify_result.extra.get("data", [{}])[0].get("count", 0)
                logger.debug(f"| ✅ Bars data inserted for {symbol}. Total rows in {table_name}: {count}")
            else:
                logger.warning(f"| ⚠️  Insert succeeded but couldn't verify count for {symbol}")
            
            # Update cache
            self._update_cache(symbol, db_data)
            
            # Calculate and store indicators
            await self._calculate_and_store_indicators(symbol)
            
            return True
            
        except Exception as e:
            logger.error(f"Error inserting bars data for {symbol}: {e}")
            return False