Pipeline de datos de clickstream completamente serverless en AWS que ingesta, transforma y almacena eventos en Parquet usando API Gateway, Kinesis, Firehose, Lambda y Athena, con IaC listo para producción mediante AWS SAM.
Código abierto. Nuevas posibilidades.
Descubre proyectos de código abierto de calidad, envía proyectos de forma anónima y reclama y edita tu propio proyecto.
Un poco de curiosidad. Un mundo de código abierto.
THE FIRST COLLECTIONAllSource es un almacén de eventos nativo de IA construido en Rust, con ingesta de alta velocidad, lecturas de baja latencia e integración nativa MCP para agentes de IA. Soporta origen de eventos duradero sin Postgres, incluye un motor de memoria de agente y ofrece ediciones comunitarias y empresariales.
go-kafka es un módulo de Go bajo licencia MIT que proporciona bloques de construcción acotados y explícitos para productores, consumidores, reproducciones, inspecciones y transacciones de Apache Kafka, envuelto alrededor de franz-go.
Lexos es un motor de procesamiento de documentos con IA basado en eventos, que combina una puerta de enlace Go, trabajadores Python, colas Redis y modelos autoalojados para RAG, resumen y transcripción de voz sin conexión.
Watermill es una biblioteca de Go para construir aplicaciones dirigidas por eventos con flujos de mensajes. Ofrece una interfaz simple para mensajería pub/sub, compatible con Kafka, RabbitMQ, NATS, Redis, SQL y más.
Un framework opinionated basado en Node.js y TypeScript que trata a AWS Lambda como ciudadano de primera clase, ofreciendo soporte para eventos de dominio DDD, transacciones Unit of Work y facturación SaaS.
PAPAI es un agente personal de IA proactivo para gestionar tareas en lenguaje natural a través de Telegram, Mattermost, Discord y Kontur Talk, con integración en Kaneo y YouTrack.
Hatchet es un motor de orquestación de código abierto para tareas en segundo plano, agentes de IA y flujos de trabajo duraderos. Soporta Python, TypeScript, Go y Ruby mediante autoalojamiento o Hatchet Cloud. Incluye reintentos configurables, trabajos cron, DAGs, monitoreo en tiempo real y multiinquilinato.