Regroupement des données Websocket dans les rails et enregistrement une fois par minute

Question

J'ai des données de prix rapides arrivant via une socket Web. Je veux le sérialiser au format correct et le rediffuser à un autre websocket à mon frontend Ember. Je veux également agréger les données une fois par minute et les enregistrer dans la base de données des rails.

La sérialisation/réémission et l'agrégation/mise en cache sont-elles possibles dans les rails? Je voudrais savoir si j'y vais de la bonne façon. Si oui, quel mécanisme de mise en cache est là et comment puis-je faire en sorte que cela se produise exactement une fois par minute?

Answer 1

Pour répondre à ma propre question, j'ai trouvé qu'il était facile de vider les données de socket web dans InfluxDB qui a agrégation et auto-suppression des anciennes données. Je n'ai pas interfacé avec les rails, mais un simple script node.js était facile en suivant leur exemple de code.

Un travail énorme pour le faire avec des rails/redis ou quelque chose.