TheSchwartz ã®ã‚ˆã†ãª RDBMS ã‚’ã¤ã‹ã£ãŸã‚¸ãƒ§ãƒ–ã‚ューをリアルタイムã«å‡¦ç†ã™ã‚‹ã‚¢ã‚¤ãƒ‡ã‚£ã‚¢ - tokuhirom's blogTheSchwartz ã®ã‚ˆã†ãª RDBMS ã‚’ã¤ã‹ã£ãŸ job queue ã¯ã€æ–°è¦ã« daemon ã‚’ãŸã¦ãŸã‚Šã™ã‚‹å¿…è¦ãŒãªã„ã®ã§æ¥½ã§ã„ã„ã®ã§ã™ãŒã€ä¸€æ–¹ã§ job ã®è¿½åŠ ã® timing ㌠storage ã‹ã‚‰ push ã§ãŠãられã¦ã“ãªã„ã®ã§ã€è‹¥å¹²ã® delay ãŒç”Ÿã˜ã¦ã—ã¾ã†ã®ãŒé›£ç‚¹ã§ã—ãŸã€‚ ã“ã®å•é¡Œã‚’解決ã™ã‚‹ãŸã‚ã«ã€mysql ã® binlog API を用ã„ã¦ã€å‡¦ç†ã—ã¦ã¿ã‚‹ãƒãƒƒã‚¯ã‚’考ãˆã¦ã¿ã¾ã—ãŸã€‚ binlog API を利用ã™ã‚‹ã¨æ›´æ–°ã‚¯ã‚¨ãƒªã‚’ streaming ã§å‡¦ç†ã§ãã‚‹ã®ã§ã€ã“ã†ã„ã£ãŸãƒãƒƒã‚¯ã‚‚ç°¡å˜ã«ã§ãã¡ã‚ƒã„ã¾ã™ã€‚ãŠã‚‚ã—ã‚ã„。 use 5.016000; use MySQL::BinLog; use TheSchwartz; my $sch = TheSchwartz->new(...) or die; $sch->can_do($_) for ...; $sch->w
{{#tags}}- {{label}}
{{/tags}}