SimpleMule para Node.js

[Angel Java Lopez]

Hola gente!

Hoy estuve programando algo rapido, pero que puede servir para ver lo flexible que es JavaScript y Node.js. Ayer estuve en la sede de MuleSoft en Buenos Aires, y siempre me queda la impresion de que las ideas centrales del producto Mule de Java se pueden reproducir en otras tecnologias, y de forma simple. Hoy es un gran producto, pero lleno de plugins graficos, etc.. Cuando en alguna reunion pedi ver codigo de como se hace un conector, no pudieron encontrarlo ;-) entre tanta UI

(Atencion: no digo que no me guste el producto, digo que es tiempo de explorar alternativas simples)

Entonces, hoy, que es feriado en Argentina, ni lerdo ni perezoso, codifique en apenas hora y minutos (porque al final tuve que actualizar el README.md ;-) el

https://github.com/ajlopez/SimpleMule

ver historia de commits de version 0.0.1, con TDD

https://github.com/ajlopez/SimpleMule/commits/master

Claro, ahora hay que codificar componentes. Pero me parece mas simple que el Mule actual, mas flexible que Storm (sin ACK con XOR, no hasta que alguien lo pida, pero hay que considerar que como Mule, no es distribuido, lo que se pueden armar es topologias que se comuniquen entre si), y pueden poner como componentes cualquier lector de colas que quieran, etc...

Nos leemos!

Angel "Java" Lopez
@ajlopez

[Iván de Praadoo]

Angel, gracias por compartir!

A raíz de lo que has puesto y echando un vistazo rápido, parece cómo que Mule esta más pensado para la coordinación de sistemas distribuidos... no así tanto para la analítica real-time (donde estaría Storm), ¿no crees? 

Por cierto, hablando de sistemas de procesamiento real-time, estuve echandole un vistazo a Spark Streaming (http://spark-project.org/docs/latest/streaming-programming-guide.html). Muy interesante para el procesamiento real-time. Aquí tenéis el paper http://www.eecs.berkeley.edu/Pubs/TechRpts/2012/EECS-2012-259.pdf 

Se basa en el concepto de micro-batches. La idea es replicar el procesamiento batch de toda la vida (tipo Hadoop), pero con ventanas de eventos muy pequeñas, entre medio segundo y un segundo. Así se puede ofrecer semántica "only-once" de procesamiento de mensajes de modo sencillo. La verdad es que me pareció muy interesante. A priori me resulta más interesante que Storm. 

Si que es cierto que Storm puro está basado en eventos, y que sólo puede ofrecer semántica "at-least-once". Aunque con Trident (http://www.datasalt.es/2013/04/un-vistazo-a-la-api-de-trident-storm/) Storm ofrece un concepto similar basado en micro-batches y con soporte de semántica "only-once", eso sí, con la ayuda de una base de datos de fondo. 

Bueno, pues eso, que me enrollo. Que Spark Streaming me ha resultado muy interesante.

Iván

2013/7/9 Angel Java Lopez <ajlop...@gmail.com>

--
Has recibido este mensaje porque estás suscrito al grupo "spain-scalability-users" de Grupos de Google.
Para anular la suscripción a este grupo y dejar de recibir sus correos electrónicos, envía un correo electrónico a spain-scalability...@googlegroups.com.
Para obtener más opciones, visita https://groups.google.com/groups/opt_out.