Kafka+Spark Streaming+Elasticserachã«ã‚ˆã‚‹ã‚·ã‚¹ãƒ†ãƒ 構築ã¨æ¤œè¨¼ã®é€²ã‚æ–¹ã¯ã˜ã‚ã« å‰å›žã¯Spark Streamingã®æ¦‚è¦ã¨æ¤œè¨¼ã‚·ãƒŠãƒªã‚ªã€ãŠã‚ˆã³æ§‹ç¯‰ã™ã‚‹ã‚·ã‚¹ãƒ†ãƒ ã®æ¦‚è¦ã‚’解説ã—ã¾ã—ãŸã€‚今回ã¯ã‚·ã‚¹ãƒ†ãƒ ã®è©³ç´°æ§‹æˆã¨æ¤œè¨¼ã®é€²ã‚æ–¹ã€ãŠã‚ˆã³åˆæœŸè¨å®šã«ãŠã‘る性能測定çµæžœã«ã¤ã„ã¦è§£èª¬ã—ã¾ã™ã€‚ ã“ã®æ¤œè¨¼ã§ã¯ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚ューã®Kafkaã€ã‚¹ãƒˆãƒªãƒ¼ãƒ データ処ç†ã®Spark Streamingã€æ¤œç´¢ã‚¨ãƒ³ã‚¸ãƒ³ã®Elasticsearchを組ã¿åˆã‚ã›ãŸãƒªã‚¢ãƒ«ã‚¿ã‚¤ãƒ ã®ã‚»ãƒ³ã‚µãƒ‡ãƒ¼ã‚¿å‡¦ç†ã‚·ã‚¹ãƒ†ãƒ を構築ã—ã¦ã„ã¾ã™ã€‚今回ã¯Kafkaã¨Elasticsearchã®è©³ç´°ãªã‚¢ãƒ¼ã‚テクãƒãƒ£ã‚„Kafkaã¨Sparkã®æŽ¥ç¶šæ™‚ã®æ³¨æ„点も解説ã—ã¾ã™ã€‚ システムã®è©³ç´°æ§‹æˆ マシン構æˆã¨ãƒžã‚·ãƒ³ã‚¹ãƒšãƒƒã‚¯ 評価ã«å‘ã‘ãŸãƒžã‚·ãƒ³ã®åˆæœŸæ§‹æˆã‚’図1ã«ç¤ºã—ã¾ã™ã€‚本システムã¯ä»¥ä¸‹ã®ãƒŽãƒ¼ãƒ‰ã‹ã‚‰æ§‹æˆã•ã‚Œã¾ã™ã€‚ センサデータをåŽé›†ã—ã¦Kafkaã«é€ä¿¡ã™ã‚‹åŽé›†ãƒ»é…信ノード Kafkaクラスタを構æˆã—ã¦ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã®å—ã‘渡ã—ã‚’è¡Œã†ã‚ューã¨ã—ã¦
ç”°ä¸è£•ä¸€ | Sparkã¯ã€èª°ã‚‚æ€ã„ã¤ã‹ãªã‹ã£ãŸãƒ“ッグデータã®ä½¿ã„方を教ãˆã¦ãれる㋠« INNOVATION INSIGHTS
{{#tags}}- {{label}}
{{/tags}}