Akka Streamsã§MySQLã‹ã‚‰ãƒ‡ãƒ¼ã‚¿ã‚’å–å¾—ã—ã¦CSVã«æ›¸ã出㙠| DevelopersIOã“ã‚“ã«ã¡ã¯ã€‚山崎ã§ã™ã€‚ MySQLã®ãƒ‡ãƒ¼ã‚¿ã‚’CSVã«æ›¸ã出ã™ãƒãƒƒãƒå‡¦ç†ã‚’Akka Streamsã§å®Ÿè£…ã™ã‚‹æ–¹æ³•ã‚’紹介ã—ã¾ã™ã€‚ Akka Streamsã¨ã¯ ノンブãƒãƒƒã‚ングãªãƒãƒƒã‚¯ãƒ—レッシャ付ãã®éžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¨™æº–を定ã‚ã‚‹Reactive Streamsã®Akkaを使ã£ãŸå®Ÿè£…ã§ã™ã€‚ Akka Streamsã«é–¢ã—ã¾ã—ã¦ã¯ã€ã“ã¡ã‚‰ã®è¨˜äº‹ã«è©³ã—ãã¾ã¨ã¾ã£ã¦ã„ã¾ã™ã®ã§ã”覧ãã ã•ã„。 実際ã«ã‚³ãƒ¼ãƒ‰ã‚’書ã„ã¦ã¿ã‚‹ 今回ã¯ã€Œå•†å“ã®æƒ…å ±ã‚’DBã‹ã‚‰å–å¾—ã—CSVファイルã«æ›¸ã出ã™ã€ã¨ã„ã†ä¾‹ã§å®Ÿè£…ã—ã¦ã„ãã¾ã™ã€‚ 処ç†ã¯ï¼“ã¤ã®éƒ¨å“ã‹ã‚‰æ§‹æˆã•ã‚Œã¾ã™ DBã‹ã‚‰å•†å“ã®æƒ…å ±ã‚’å–å¾—ã™ã‚‹Source æµã‚Œã¦ããŸå•†å“æƒ…å ±ã‚’CSVã®1行分ã«å¤‰æ›ã™ã‚‹Flow ファイルã«æµã—込むSink ã“れらã®éƒ¨å“を実装ã—ã¦ã¤ãªã’ã‚‹ã“ã¨ã§å‡¦ç†ã‚’実装ã—ã¾ã™ã€‚ 実際ã«ã‚³ãƒ¼ãƒ‰ã‚’見ã¦ã„ãã¾ã—ょã†ã€‚ ä¾å˜é–¢ä¿‚ 今回使用ã™ã‚‹ãƒ©ã‚¤ãƒ–ラリをbuild.s
{{#tags}}- {{label}}
{{/tags}}