Akka gRPC（Scala）+CloudTraceで分散トレーシング
はじめに CloudTraceとは 概要はこちら。 GCP曰く「誰でも使用できる分散トレース システム」とのことで、GKE上で動かしているAkka gRPCで書かれたサービスのトレース結果を下のイメージ（クイックスタートより拝借）のように見たいなぁというのが今回の動機。 Scala環境ではOpenTelemetry（Java）を利用できそうです。 OpenTelemetryとは 概要はこちら。 Google翻訳によると「OpenTelemetryは、トレース、メトリック、ログなどのテレメトリデータの作成と管理用に設計された、API、SDK、ツール、および統合のセットです。」らしい。 OpenTracingとOpenCensusの合併した後継プロジェクトであり、CNCFのインキュベーターになっています。 Java以外にもGoとか.Netとか用意されているみたいですね。 Akka gRPCで利
akka http clientのmax-open-requestsについて | DevelopersIO
はじめに akka http client APIを使っていて以下のようなエラーに遭遇したので関連する設定について調べました。 akka.stream.BufferOverflowException: Exceeded configured max-open-requests value of [4]. これは何か？ エラーメッセージに記載されている説明ページには以下のように説明されています(要約) ホストごとにコネクションをプーリングしている コネクション数は akka.http.host-connection-pool.max-connectionで設定する プールを使うAPI(Http().singleRequest()など）でリクエストを送信すると、プールが処理できるリクエスト数を超えた場合はキューに入れられる キューのサイズ(max-open-requests) を超えた場合はB
AkkaのPersistence (Event Sourcing)の用途について
この記事はScala Advent Calendar 2021の16日目の記事です。 はじめに Akka Clusterを使った分散システムを実現するために、いくつかのAkkaのモジュールを理解する必要がある。 そのうちの一つにPersistence (Event Sourcing) がある。よく Actor を永続化するために使うということを聞くが、あまり使い所がピンと来なかったので、Akkaのドキュメントと参考文献を読みながらメモを書いていく。 Persistence (Event Sourcing) とは 状態を持ったアクターを永続化できるモジュール。 以下の二種の方法で永続化ができる Journal - 更新イベントを1つずつ発生した順番に保存 Snapshot - その時点でのActorの状態を直接保存 状態を持ったアクターのスナップショットも使うことはできるが(リカバリーする際
Akka HTTPの仕組みを理解する
LINE株式会社は、2023年10月1日にLINEヤフー株式会社になりました。LINEヤフー株式会社の新しいブログはこちらです。 LINEヤフー Tech Blog 初めまして、Ads Platform開発チームの岡田（@ocadaruma）です。 この記事はLINE Advent Calendar 2017の17日目の記事です。 今回、個人的に以前から気になっていたAkka HTTPの内部構造について、この機会に調べましたので紹介いたします。 Akka HTTPとは Akka HTTPは、Lightbend社によって開発されている、Scala/Java用のHTTP toolkitです。 現在はメンテナンスが終了したsprayの後継と位置付けられており、特徴的なRouting DSLをsprayから受け継いでいます。 また、Play Frameworkは2.6系より、Akka HTTPをデ
Scala. js+React+akka-httpでオンライン対戦可能なオセロを作ってみる - Qiita
使用ライブラリなど Scala.js scalajs-react akka-http circe モデリング ゲームのコアにあたる部分の実装指針です。 オセロのルールを閉じ込めたOthelloクラスを作成し、以下の2つの状態を保持 ボード ... 盤面。どこに何色の石が置かれているかを保持。 手番 ... 次は黒/白どちらの手番か（これは、通常プレイであれば、ボード上の石数から判断することも出来るものの、通常プレイ以外の拡張モードの構想もあり、切り出すことにしました） ゲームの情報を保持するGameクラスを作成し、勝敗や参加者のIDを保持 このクラスがOthelloインスタンスを内包しています。 参加者はParticipantクラスで定義 名前と状態（フリー、参加待ち、観戦中、対戦中）を持っています。 認証認可周りは今回の本題ではないので、ふわっと作ってます。 実装戦略 以下、どういった方
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
Akka Streams についての基礎概念 - Qiita
Akka Streams が2.4以降からexperimentalを外して、正式版をリリースしました。丁度会社で3日のHackerDaysを機に、Akka Streams を勉強しはじめました。 この記事では、AkkaStreamの公式ドキュメントを抜粋し、翻訳しながら、AkkaStreamの基礎概念を説明します。 Akka Streams ってなに 背景 今のInternet上、我々は膨大なデータを消費している。その大量のデータを人々はビッグデータと呼んでいるw。 もう昔みたいにデータを全部ダウンロードして処理、処理完了してアップロード的な処理は時間掛かりすぎ、そもそも一台のサーバに保存しきれないデータは処理できないので、Streamみたいな流れとしての処理が必要になっている。 Akkaが使うActorモデルもその一例、データを分割し、メッセージとしてActorに送る、Actorは只々流
Alpakka で AWS SQS 接続 (Scala) - OPEN8テックブログ
はじめに Alpakka Alpakka とは セットアップ AWS SQS AWS SQS とは ElasticMQ のセットアップ Alpakka で AWS SQS 接続 Subscribe Publish さいごに はじめに こんにちは、オープンエイトの山崎です。 今回は、Akka Streams で Alpakka を使って AWS SQS と接続しデータを送受信する方法について説明します。また本記事内では AWS SQS をローカル環境でシミュレートするために ElasticMQ を使用します。ElasticMQ のセットアップについてもあわせて簡単に説明します。記事執筆時の環境は以下の通りです。 Scala 2.13.5 sbt 1.4.7 Akka 2.6.13 Alpakka SQS 2.0.2 ElasticMQ 1.1.0 オープンエイトでは、SNS 配信効果測定サー
LINE DEVELOPER DAY 2016 開催のお知らせ « LINE Engineers' Blog
LINE株式会社は、2023年10月1日にLINEヤフー株式会社になりました。LINEヤフー株式会社の新しいブログはこちらです。 LINEヤフー Tech Blog saegusa2017-04-16Yoshihiro was a network engineer at LINE, responsible for all levels of LINE's infrastructure. Since being named Infra Platform Department manager, he is finding ways to apply LINE's technology and business goals to the platform. こんにちは。LINEでネットワークやデータセンターを担当している三枝です。2017年1月にJANOG39で登壇する機会を頂きましたので、今回
日本一わかりやすいというほどでもない Akka2.2 の IO まわりと Pipeline まわり - 猫型の蓄音機は 1 分間に 45 回にゃあと鳴く
！！！！！！この記事は古い情報を扱っています！！！！！！ Akka 2.3 からは Pipeline はなくなっています。この記事の内容は古いです。気をつけてください 前回までのあらすじ 自信満々で日本一わかりやすい Akka の IOManager と SocketHandle(やServerHandle)、それに IO.Iteratee と IO.IterateeRef というブログ記事を書いたしんぺい a.k.a. 猫型蓄音機。しかし彼を待ち受けていたのは、「それ 2.2 から deprecated になるよ」という無慈悲な現実であった。Akka 2.2 から使われることになる akka.io と Pipeline という新しい敵が待ち受ける中、しんぺいは日本一わかりやすい記事を書けるのだろうか？ という感じでした。それでは書いていきます。Akkaのバージョンは2.2.0-RC1です
Scala + akka で簡単なチャットサーバーを書いてみたので解説してみるよ - 猫型の蓄音機は 1 分間に 45 回にゃあと鳴く
！！！CAUTION！！！ この記事で扱っている IO のインターフェイスは Akka 2.2 で すでに old-io 扱いとなり( http://doc.akka.io/docs/akka/2.2.0/scala/io-old.html )、Akka 2.3 からは削除されてしまっています。 今ならばこちらを参考にされたほうがいいでしょう。 I/O まわり： http://doc.akka.io/docs/akka/2.3.7/scala/io.html TCPのハンドリング：http://doc.akka.io/docs/akka/2.3.7/scala/io-tcp.html 本文 akka というのは Scala で Actor モデルを実現するためのライブラリだと思えばいいっぽい。この記事を読むためには case class とパターンマッチとアクターモデルについての知識が最低
Google グループ
Google グループでは、オンライン フォーラムやメール ベースのグループを作成したり、こうしたフォーラムやグループに参加したりすることで、大勢のユーザーと情報の共有やディスカッションを行うことができます。
Google グループ
Google グループでは、オンライン フォーラムやメール ベースのグループを作成したり、こうしたフォーラムやグループに参加したりすることで、大勢のユーザーと情報の共有やディスカッションを行うことができます。
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
[Akka-HTTP]ルーティングDSLの基本となるPathMatcherのまとめ - Qiita![[Akka-HTTP]ルーティングDSLの基本となるPathMatcherのまとめ - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/d2bf6e06f735b9349d0ade6fda9a3eaaaebb10e4/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fqiita-user-contents.imgix.net%252Fhttps%25253A%25252F%25252Fcdn.qiita.com%25252Fassets%25252Fpublic%25252Farticle-ogp-background-afbab5eb44e0b055cce1258705637a91.png%253Fixlib%253Drb-4.0.0%2526w%253D1200%2526blend64%253DaHR0cHM6Ly9xaWl0YS11c2VyLXByb2ZpbGUtaW1hZ2VzLmltZ2l4Lm5ldC9odHRwcyUzQSUyRiUyRnFpaXRhLWltYWdlLXN0b3JlLnMzLmFtYXpvbmF3cy5jb20lMkYwJTJGMjgwJTJGcHJvZmlsZS1pbWFnZXMlMkYxNDczNjgzNTQ0P2l4bGliPXJiLTQuMC4wJmFyPTElM0ExJmZpdD1jcm9wJm1hc2s9ZWxsaXBzZSZmbT1wbmczMiZzPWJiYzU3MzBhNDZjOWI5YTY5YTI1MGQ4MTJlOTFhNDky%2526blend-x%253D120%2526blend-y%253D467%2526blend-w%253D82%2526blend-h%253D82%2526blend-mode%253Dnormal%2526s%253D0b8489be8ce638fe54e50170a35092f5%3Fixlib%3Drb-4.0.0%26w%3D1200%26fm%3Djpg%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTk2MCZoPTMyNCZ0eHQ9JTVCQWtrYS1IVFRQJTVEJUUzJTgzJUFCJUUzJTgzJUJDJUUzJTgzJTg2JUUzJTgyJUEzJUUzJTgzJUIzJUUzJTgyJUIwRFNMJUUzJTgxJUFFJUU1JTlGJUJBJUU2JTlDJUFDJUUzJTgxJUE4JUUzJTgxJUFBJUUzJTgyJThCUGF0aE1hdGNoZXIlRTMlODElQUUlRTMlODElQkUlRTMlODElQTglRTMlODIlODEmdHh0LWFsaWduPWxlZnQlMkN0b3AmdHh0LWNvbG9yPSUyMzFFMjEyMSZ0eHQtZm9udD1IaXJhZ2lubyUyMFNhbnMlMjBXNiZ0eHQtc2l6ZT01NiZ0eHQtcGFkPTAmcz0xZDY5ODJkNDk0OTQ4ZGY0YmJkNGZkMzcwMDAzMmYxOQ%26mark-x%3D120%26mark-y%3D112%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTgzOCZoPTU4JnR4dD0lNDBwZXRpdHZpb2xldCZ0eHQtY29sb3I9JTIzMUUyMTIxJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTM2JnR4dC1wYWQ9MCZzPTZlZjUwOTFhNzg2ZGUxZGE1NmQyZGUxNDQxMGEzZjVm%26blend-x%3D242%26blend-y%3D480%26blend-w%3D838%26blend-h%3D46%26blend-fit%3Dcrop%26blend-crop%3Dleft%252Cbottom%26blend-mode%3Dnormal%26s%3Db7cd0c17f9820b8442af1b78e70f3183)
Reading an Akka-HTTP Response Body as a String | Baeldung on Scala
AWSでCQRS Event Sourcing するにはどうすればいいのか
Dynamically changing the throttling level on Akka Streams
【参加レポ】Akka ActorとAMQPでLINEのメッセージングパイプラインをリプレースした話【LINE DEVELOPER DAY_2015】 #linedevday - もぐめぽろぐ
Get Started with Lightbend Technologies | Lightbend Tech Hub
Starting multiple remote servers with Akka