Lightbend Fast Data Platform
The Lightbend Fast Data Platform is designed to facilitate the building of streaming data systems and applications, offering best practices, guidance, and intelligent monitoring for resilience. It converges fast data with microservices, highlighting the importance of addressing similar design problems and the dominance of data issues. The platform supports multiple data sources, with an emphasis o
Building Reactive Fast Data & the Data Lake with Akka, Kafka, Spark
Building Reactive Fast Data & the Data Lake with Akka, Kafka, SparkAI-enhanced description The document presents a draft presentation on building reactive fast data and data lakes using technologies like Akka, Kafka, and Spark. It highlights the principles of reactive systems, their historical context, and the evolution of methodologies aimed at improving scalability and real-time data processing.
Akka Clusterã®è€éšœå®³è¨è¨ˆ
大é‡ã®ãƒ‡ãƒ¼ã‚¿å‡¦ç†ã‚„分æžã«ä½¿ãˆã‚‹OSS Apache Spark入門（Open Source Conference 2021 Online/Kyoto 発表資料）
最新DDDアーã‚テクãƒãƒ£ã¨Akkaã§ã®å®Ÿè£…ヒントã«ã¤ã„ã¦
DDD+CQRS+Event Sourcingã¨Akkaã§ã®å®Ÿè£…ヒントを解説。
CQRS+ESã‚’Akka Persistenceを使ã£ã¦å®Ÿè£…ã—ã¦ã¿ã‚‹ã€‚
Grafana Lokiã§ã¯ã˜ã‚ã‚‹Kubernetesãƒã‚®ãƒ³ã‚°ãƒãƒ³ã‚ºã‚ªãƒ³ï¼ˆNTT Tech Conference #4 ãƒãƒ³ã‚ºã‚ªãƒ³è³‡æ–™ï¼‰
ExecutionContextã¨blockingã«ã¤ã„ã¦èª¿ã¹ãŸãƒ¡ãƒ¢ [scala] - ã ã„ãŸã„よãã‚ã‹ã‚‰ãªã„ブãƒã‚°
ã“ã®è¨˜äº‹ã®çµè«– globalãªExecutionContextã§ã¯ãƒ–ãƒãƒƒã‚¯ã™ã‚‹å‡¦ç†ã‚’blockingã§åŒ…ã‚€ã¨ã‚¹ãƒ¬ãƒƒãƒ‰æ•°ãŒå‹æ‰‹ã«å¢—ãˆã‚‹ã‹ã‚‰ç©ºãスレッドãŒç„¡ãã¦å®Ÿè¡Œã§ããªã„ã¨ã„ã£ãŸã“ã¨ã‚’防ã’る。 ExecutionContext.fromExecutorService(new ForkJoinPool(100)) ã§ç”Ÿæˆã•ã‚Œã‚‹Threadã¯BlockContextトレイトを継承ã—ã¦ãªã„ã®ã§blockingを使ã£ã¦ã‚‚スレッド数を増やã—ãŸæ–¹ãŒè‰¯ã„ã¨ã„ã†æƒ…å ±ãŒã‚¹ã‚±ã‚¸ãƒ¥ãƒ¼ãƒ©ã«ä¼ã‚らãªã„。 akkaã®dispatcherã‚’ExecutionContextã¨ã—ã¦ä½¿ã†ã¨BlockContext付ãã®ForkJoinPoolã‚’ç°¡å˜ã«ä½œã‚Œã‚‹ã€‚ ExecutionContext.fromExecutorServiceã§ã‚‚ForkJoinPoolã®ã‚³ãƒ³ã‚¹ãƒˆãƒ©ã‚¯ã‚¿ã«è‡ªå‰å®šç¾©ã—ãŸThreadFactoryを渡ã™ã‚ˆã†ã«ã™
![ExecutionContextã¨blockingã«ã¤ã„ã¦èª¿ã¹ãŸãƒ¡ãƒ¢ [scala] - ã ã„ãŸã„よãã‚ã‹ã‚‰ãªã„ブãƒã‚°](https://cdn-ak-scissors.b.st-hatena.com/image/square/230742208db3c7d858546f12bd7620b3fbb92bb9/backend=imagemagick;height=288;version=1;width=512/https%3A%2F%2Fogimage.blog.st-hatena.com%2F6435988827676774280%2F10328537792366453099%2F1499073542)
Classic FSM • Akka core
The Akka dependencies are available from Akka’s secure library repository. To access them you need to use a secure, tokenized URL as specified at https://account.akka.io/token. To use Finite State Machine actors, you must add the following dependency in your project: sbtval AkkaVersion = "2.10.17" libraryDependencies += "com.typesafe.akka" %% "akka-actor" % AkkaVersionMaven<properties> <scala.bina
アクターã®è«¸åˆƒã®å‰£ï¼šéžåŒæœŸã®ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãƒ‘ッシングã¨çŠ¶æ…‹éš”離対障害モデルã€ãã—ã¦ãれを克æœã™ã‚‹Akka Streamã®å¯èƒ½æ€§ - TanUkkiiã®ãƒ–ãƒã‚°
Scalaã®ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ©ã‚¤ãƒ–ラリã§ã‚ã‚‹Akkaã§ã¯ä»Šã¾ã§HTTPãŒIOパッケージã§ã‚µãƒãƒ¼ãƒˆã•ã‚Œã¦ãã¾ã›ã‚“ã§ã—ãŸã€‚HTTPã®ã‚µãƒãƒ¼ãƒˆã¯Akka Streamã®é–‹ç™ºã¨ã¨ã‚‚ã«ãªã•ã‚ŒãŸã®ã§ã™ã€‚ãªãœã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ã¨HTTPã‚’ã™ãçµ±åˆã›ãšã«Streamã®ç™»å ´ã‚’å¾…ã¤ã“ã¨ã«ãªã£ãŸã®ã‹ï¼Ÿã“ã®ç–‘å•ã«ç”ãˆã‚‹ã“ã¨ã¯ã‚¢ã‚¯ã‚¿ãƒ¼ã®å•é¡Œã‚’考ãˆã‚‹ã‚ˆã„é¡Œæã§ã™ã€‚ Sprayã®é©æ–°ã¨ãã®é™ç•Œ Sprayã¯Akkaã®ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ã¨HTTPã‚’çµ±åˆã—ã¦æˆåŠŸã—ãŸãƒ•ãƒ¬ãƒ¼ãƒ ワークã§ã™ã€‚Sprayã¯JVMベースã®ãƒ•ãƒ¬ãƒ¼ãƒ ワークã®ä¸ã§æœ€é«˜ã®ãƒ‘フォーマンスを誇りã¾ã—ãŸã€‚Sprayã¯ServletãŒã‚‚ã¤ãŒã‚¹ãƒ¬ãƒƒãƒ‰ã®é«˜é€Ÿæ€§ã¨ã€NodeJSãŒã‚‚ã¤ã‚¤ãƒ™ãƒ³ãƒˆãƒ«ãƒ¼ãƒ—ã«ã‚ˆã‚‹å¤§é‡ã®ãƒªã‚¯ã‚¨ã‚¹ãƒˆã‚’効率的ã«æŒãã“ã¨ã®ç‰¹æ€§ã®ä¸¡ç«‹ã‚’ã€ã‚¢ã‚¯ã‚¿ãƒ¼ã«ã‚ˆã£ã¦å¯èƒ½ã«ã—ãŸã®ã§ã™ã€‚ ã¨ã“ã‚ãŒSprayã¯ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ãªã‚‰ã§ã¯ã®å•é¡Œã¨ã‚‚戦ã†ã“ã¨ã«ãªã‚Šã¾ã™ã€‚Reactive Manife
SLOBSERVER - L'actualité de Second Life
Thông tin pháp lý và thà nh láºp SP666 được thà nh láºp chÃnh thức và o tháng 6 năm 2017 bởi má»™t nhóm chuyên gia trong lÄ©nh vá»±c công nghệ và giải trà trá»±c tuyến đến từ Äông Nam Ã, trong đó đứng đầu là ông David Trần, ngÆ°á»i từng là giám đốc chiến lược của má»™t táºp Ä‘oà n công nghệ game tại Singapore. SP666 được váºn hà nh bởi Công ty TNHH SP666 Online Entertainment. Trụ sở hoạt Ä‘á»™ng tại Việt Nam: 21/22B Ä. L
Akkaã®åˆ†æ•£ã•ã‚ŒãŸã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§DBを使ã‚ãšã«ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹æ–¹æ³• - Qiita
本記事㯠TIS Engineer Advent Calendar 2015 23日目ã®è¨˜äº‹ã§ã™ã€‚ ã¯ã˜ã‚ã« Akka ã§åˆ†æ•£ã‚·ã‚¹ãƒ†ãƒ を構築ã—ãŸã¨ãã«ã€åˆ†æ•£ã•ã‚ŒãŸè¤‡æ•°ã®ã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§å¸¸ã«æ›´æ–°ã•ã‚Œã‚‹ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ã“ã¨ã‚’考ãˆã¾ã™ã€‚DBを使ã‚ãšã«ã‚„ã‚ã†ã¨ã™ã‚‹ã¨ã€å…±æœ‰ãƒ‡ãƒ¼ã‚¿ã‚’管ç†ã™ã‚‹ãŸã‚ã®ã‚¢ã‚¯ã‚¿ãƒ¼ã‚’1ã¤ä½œã£ã¦ãŠãã€å¸¸ã«ãã®ã‚¢ã‚¯ã‚¿ãƒ¼ã«ãƒ‡ãƒ¼ã‚¿ã®å–å¾—ã¨æ›´æ–°ã‚’ä¾é ¼ã™ã‚‹ã¨ã„ã†æ–¹æ³•ãŒæ€ã„ã¤ãã¾ã™ã€‚ã—ã‹ã—ã€ã“ã®æ–¹æ³•ã§ã¯ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ãŸã‚ã®ã‚¢ã‚¯ã‚¿ãƒ¼ãŒå˜ä¸€éšœå®³ç‚¹ã«ãªã£ã¦ã—ã¾ã†ã¨ã„ã†ã“ã¨ã¨ã€ãã®éƒ¨åˆ†ã®ã‚¹ã‚±ãƒ¼ãƒ©ãƒ“リティを確ä¿ã§ããªã„ã¨ã„ã†å•é¡ŒãŒã‚ã‚Šã¾ã™ã€‚ è€éšœå®³æ€§ã¨ã‚¹ã‚±ãƒ¼ãƒ©ãƒ“リティを確ä¿ã—ãŸã¾ã¾ã€Akkaã®ã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ã«ã¯ã©ã†ã™ã‚Œã°è‰¯ã„ã®ã§ã—ょã†ã‹ï¼Ÿã“ã†ã„ã†ã‚±ãƒ¼ã‚¹ã§ã¯ Akka ã® Distributed Data ã¨ã„ã†ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ãŒä½¿ãˆã¾ã™ã€‚Distributed Data を使ã†ã¨ã€DBを使ã‚ãšã«
Akka Cluster Shardingã§å³æ™‚集計系をã¤ãã‚‹ | Scala Tech Blog
ã“ã‚“ã«ã¡ã¯ã€CA ProFit-X ã®æ¾æ‘ã§ã™ã€‚ ç§ãŸã¡ã®ãƒ—ãƒãƒ€ã‚¯ãƒˆã§ã¯åºƒå‘Šé…ä¿¡ã®ã‚·ã‚¹ãƒ†ãƒ ã«Akkaを使ã£ã¦ã„ã¦ã€ã‚¢ãƒ—リケーションã¯AWS/Docker環境ã«é…å‚™ã—ã¦é‹ç”¨ã—ã¦ã„ã¾ã™ã€‚今回ã¯Akkaã®Cluster Shardingã¨ã„ã†æ‹¡å¼µã‚’使ã£ã¦ã€ä¸»ã«AWS環境を想定ã—ãŸç°¡å˜ãªãƒªã‚¢ãƒ«ã‚¿ã‚¤ãƒ 集計システム(å³æ™‚集計系)ã‚’ã¤ãã£ã¦ã¿ãŸã®ã§ãã®å†…容をã”紹介ã—ã¾ã™ã€‚ 下ã§ã¯Akka Cluster Shardingã«ã¤ã„ã¦ç°¡å˜ã«èª¬æ˜Žã—ãŸå¾Œã€è©¦ä½œã—ãŸå³æ™‚集計系ã®å®Ÿè£…・永続化ã¨é…å‚™ã«ã¤ã„ã¦èª¬æ˜Žã—ã¾ã™ã€‚ãã®å¾Œã€ãƒ¯ãƒ¼ã‚¯ãƒãƒ¼ãƒ‰ã¨ãƒŽãƒ¼ãƒ‰æ•°ã‚’増減ã•ã›ãŸå®Ÿé¨“ã¨ãã®çµæžœã«ã¤ã„ã¦èª¬æ˜Žã—ã¾ã™ã€‚ Akka Cluster Sharding ã«ã¤ã„㦠Akka Clusterã¯Gossip Protocolã¨Ï† Accrual Failure Detectorã¨ã„ã†æ‰‹æ³•ã«åŸºã¥ã„ãŸéžä¸å¤®é›†æ¨©çš„ãªãƒŽãƒ¼ãƒ‰ç¾¤æ§‹ç¯‰ã‚’è¡Œã†Akkaæ‹¡å¼µ
ã€Akka】Akka StreamsãŒã‚ã£ã¡ã‚ƒä¾¿åˆ©ã™ãŽã¦è„³æ±ãŒå‡ºãŸè©±ã— | Scala Tech Blog
ã“ã‚“ã«ã¡ã¯ï¼Smalgoã®ä¾†ç”°ã§ã™ã€‚ 注æ„：タイトルã¯éŽæ¿€ã§ã™ãŒå†…容至ã£ã¦æ™®é€šãªãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ«è¨˜äº‹ã§ã™ã€‚ 仕事ã§Workerを作ã£ãŸæ™‚ã«ä½¿ã£ã¦ã¿ã¦ã‚ã£ã¡ã‚ƒä¾¿åˆ©ã ã¨æ€ã£ãŸã®ã§Akka Streamsã«ã¤ã„ã¦æ›¸ããŸã„ã¨æ€ã„ã¾ã™ï¼ ã¾ã ã¾ã ä¸ã®å®Ÿè£…ã®æ·±ã„ã¨ã“ã‚ã¾ã§è¿½ãˆã¦ã‚‹ã‚ã‘ã˜ã‚ƒãªã„ã®ã§é–“é•ã£ã¦ã„ãŸã‚‰æ•™ãˆã¦ãã ã•ã„。 Akka Streamsã¨ã¯ Reactive Streams（ノンブãƒãƒƒã‚ングã§back pressureãªéžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¨™æº–仕様）ã®Akka実装 Back Pressureã¨ã¯ éžåŒæœŸãªã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®å ´åˆä¸‹è¨˜ã®å•é¡ŒãŒèµ·ãã‚‹ Publisherå´ã®å‡¦ç†ãŒæ—©ã„å ´åˆSubscriberå´ã®ãƒãƒƒãƒ•ã‚¡ãƒ¼ãŒæº¢ã‚Œã¦ã—ã¾ã† Subscriberã«é æ…®ã—ã¦Publisherå´ã®å‡¦ç†ã‚’抑ãˆãŸå ´åˆã¯ç„¡é§„ãŒå¤šããªã£ã¦ã—ã¾ã† ãれをSubscriberãŒè‡ªåˆ†ãŒå‡¦ç†ã§ãã‚‹é‡ã‚’Publisherã«
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
Reactive integrations with Akka Streams
Akka Streamsã®ç¸®é€€å‡¦ç†ã‚’用ã„ãŸè€éšœå®³æ€§ã®å®Ÿç¾ 〜 広告ã®ãƒªã‚¢ãƒ«ã‚¿ã‚¤ãƒ オークションã®äº‹ä¾‹ 〜
Akka HTTP
INTEL コード & ダウンãƒãƒ¼ãƒ‰
Akka stream
AKKA Customer Stories
https://downloads.typesafe.com/website/casestudies/images/typesafe-community-story-dwango.pdf
http://www.smartjava.org/content/visualizing-back-pressure-and-reactive-streams-akka-streams-statsd-grafana-and-influxdb/
{{#tags}}- {{label}}
{{/tags}}