Scalaの抽出子(apply, unapply)サンプルと呼ばれるタイミング - Qiita
ScalaのObject内で良くセットで定義されるメソッド、 apply (注入、injection)、unapply(抽出、extraction)。 細かい事はコップ本26章やその他の有用な記事を見るとして... unapplyメソッドを持つオブジェクトは抽出子(extractorObject)と呼ばれる。 例1 object extractorObject { // 抽出子オブジェクト object Sample { def apply(str: String): String = { // 文字列を作った str + " (applyが呼ばれた)" } // ここでの引数strはapplyが作り出した文字列 def unapply(str: String): Option[String] = { if (str.nonEmpty) Some(str + (" (unapplyも呼ばれ
Spotify Scio - Google Dataflow の Scala言語版 - Qiita
Google GCP(Google版AWS)のDataflowサービスを使ってみました。 Dataflowとは、その名の通り、膨大なデータをGoogleご自慢の分散環境を使用して並列で爆速処理してくれる、ビッグクエリーと同じGCPのマネージドサービスの１つです。 使用できるオフィシャルなプログラミング言語は、JavaとPythonのみですが、 Spotifyから、ScioというScalaのライブラリが提供されていますので今回使用してみました。 Dataflowでは、パイプラインを作成し、入力、変換1、変換2...変換N、出力の３ステップで構成します。関数型言語のScalaは、変換ロジックをラムダ式でコンパクトに記述できるため、Javaよりもコード量が少なくて済みます。 Spotifyでは、KafkaからDataflowへ移行する際に、Scalaで記述できるようにScioライブラリを開発した
Scala用DIコンテナ airframeの使い方 - Qiita
ScalaでDIコンテナというとGoogle Guiceを使っている人が多いと思うけど、僕は最近airframeを使い始めました。 何がどう違うのというのは以下の記事を読んで欲しい。個人的には、Scalaで使うための設計が前提になっているかが大きいと思っています。Guiceでもいいけど、無邪気に使っているとJava前提のライブラリはハマることもあるし、Scalaの独自機能に対するケアもないので…。 使い方はQuick Startを読んでください。たけぞえさんのブログ記事 「Scala用のDIライブラリAirframeを試してみた」 でも紹介されています。1 以上、終了でもよかったのですが、日本語で簡単に解説しておきます。 最低限知っておくとよいのは、Design, Sessionです。あとは、DIコンテナがサポートするLife Cycleはドキュメントをみてください。DesignとSess
高階型の型パラメータを持つDDDリポジトリをDIできるようにする - Qiita
DDDリポジトリを楽に実装するライブラリで紹介したscala-ddd-baseを使って実装したリポジトリをairframeを使ってDIする事例を簡単に紹介します。 リポジトリの実装は前回の記事のとおりです。UserAccountRepositoryは高階型の型パラメータM[_]を必要とします。 この例では、Task[A]のタイプエイリアスとしてBySlick[A]を宣言し、ファクトリメソッドで実装を生成できるようにしています。 object UserAccountRepository { type BySlick[A] = Task[A] def bySkinny: UserAccountRepository[BySkinny] = new UserAccountRepositoryBySkinny ｝ class UserAccountRepositoryBySkinny extends
Play の BodyParser を組み合わせる - Qiita
def save = Action { request: Request[AnyContent] => val body: AnyContent = request.body // デフォルトでは上記のように request.body は AnyContent 型です。 Content-Type ヘッダの値によって適切な型として parse されます。たとえば Content-Type が application/json であれば JSON として parse され、request.body.asJson で JSON が取り出せます。 今回はパースされたボディと共に、生のリクエストボディにアクセスしたいと思いました。 Play では BodyParser[A] が HTTP リクエストボディを解釈します。 その定義 を見るとわかるように RequestHeader => Accumul
Scalaのscala.util.TryでJavaのtry-catch-finallyを表現する - Qiita
Javaのtry-catch-finallyは致命的なエラー(FatalError)は捕捉しませんが、 Scalaのtry-catch-finallyは致命的なエラーも捕捉してしまいます。 致命的な例外として有名なのはOutOfMemoryErrorなどがあり、このような致命的な例外はプログラム中で捕捉すべきではありません。 scala> try { | throw new StackOverflowError | } catch { | case e: Throwable => println("error") | } error そこで、Scalaではtry-catch-finallyではなく、scala.util.Tryを使って例外を捕捉する方法が一般的（？）になっています。 scala.util.Tryは、Javaのtry-catch-finallyと同様に致命的ではないエラー（N
複数のモナドを同時に扱うためのネストfor式 - Qiita
前置き さて、前置きですが、モナドと書きましたが実際にはモナドではなく、モナドのようなものです。 ここで言うモナドというものは、Scalaにおけるfor式で扱えるように、以下のメソッドを実装している型のことを指します。 map/flatMap （つまり、for式で使える型、ifフィルターとyieldではないfor式を除く） あと、記事中の英語は適当です。 はじめに どこかで見た便利な書き方としてfor式のネストした形式を紹介します。（具体的な呼び名は知らない。勝手にネストfor式とか言っておく。） Scalaでのエラーハンドリングはキモくなりがちです。 Either、Try、Optionの入り混ざったものを一つのfor式で扱うのは困難で、 最初にfor式中で使用したモナドに、以降も制限されてしまいます。 scala> { | for { | result <- Future { Try("
Play Framework(Scala)で、POSTされたデータを直接requestから取得する - Qiita
概要 以前に私の方で投稿したPlay Framework 2.6(Scala)でFormの処理を作ってみたでは、Formオブジェクトを使ってPOSTのデータを取得していましたが、reuqestから直接POSTされたデータを取得する方法を紹介します。 対応方法 How to get payload from a POST in Play 2.0で紹介されている通り、requestのbodyから「asFormUrlEncoded」を使うことで取得できます。JavaでのサンプルはHyuさんのPlayFrameworkでのリクエストパラメーターの受け取り方でも紹介されています。 サンプルコード Formオブジェクトを使わない方法で、POSTされたデータを取得するScalaのサンプルソースを記載します。 @import helper._ @main("サンプル"){ <font size=5>■サン
scala, sbtでのkamon-cloudwatchの使い方 - Qiita
libraryDependencies += "com.timeout" %% "kamon-cloudwatch" % "0.0.1" kamon { metric { # 秒間60でメトリクスを取得 # これを追加しないとCloudWatchの料金が大変なことになる tick-interval = 60 second } cloudwatch { # カスタムメトリクスで表示する名前 namespace = kamon-`<アプリ名>` # Cloudwatchのリージョン region = eu-west-1 # Cloudwatchに一度に送るデータ数？ batch-size = 20 # falseだったらCloudwatchにメトリクスを送らない？ send-metrics = true # スレッドプール数 async-threads = 5 # 取得するメトリクスを指定 s
play-redisから`PeerClosed`のログが出る理由 - Qiita
問題 redis.actors.RedisClientActor - ConnectionClosed PeerClosedのWarningログが各APIのCloudWatchに出続ける（出現間隔は1分に1回） 原因 redisにtimeoutが設定されているため、timeout時間内にredisに対してread/writeの操作がなければ、redisへのコネクションを切る そのため、各APIでredisへのread/writeが頻繁に起こらない状態だと、redis側からコネクションが切られ、play-redis(scala)からPeerClosedのログが発生する。 対策 redisのtimeout値を長く取るか、定期的にreadの処理を走らせるという対策が考えられる ただし、PeerClosedのログは本番環境など、頻繁にredisへの処理が走る環境では発生しない redisにはtim
ScalaTestでテストレポートを出力する - Qiita
ScalaTestでユニットテストを書いて sbt でテストを実行すると、sbtのコンソールにはテスト結果とログがごちゃ混ぜになって出力されるかと思います。 「テスト結果のサマリーだけ見たい！！」ってときはログが邪魔ですが、かと言っていちいちログ出力レベルを変えるのも面倒、と言うときはテスト結果をレポートとして出力すると便利だと思います。 以下の例のように build.sbt で testOptions にレポート出力の設定を追加するだけでOKです。 レポートのファイル名にプロジェクト名を含めておかないと、プロジェクトごとに上書きされてしまいます。 レポートの出力内容などはオプションで調整できます。詳細は ScalaTestユーザーガイド - Writing your first test の Using Reporters の項を参照） val commonSettings = Seq(
Autodesk ForgeのJava APIについて - Qiita
Autodesk ForgeのウェブサイトがURL含めて最近大幅に変わっていて、チュートリアルも更新されています。今までは、NodeJSとかC#とかのチュートリアルしかなかったのですが、GoとかPHPなんかも増えています。JavaのSDKも少し前に出ていたらしいけれど、Servletをサンプルがしっかり公開されています。素晴らしい。 最近、Play Frameworkを触っていることもあってServletは避けたいなということで、Javaのライブラリを使ってScalaでサンプルを書いてみました。 forge-api-java-client 公式サイトはコチラです。基本的には、ForgeのREST APIのラッパーなのですが、同期的なAPIになっていたり、セッションの自動更新機能が実装されていたりで、結構使いやすい印象です（少なくともNodeJSよりは）。 ちなみに公式サイトのサンプルは、S
Play Framework 2.6(Scala)でFormにhiddenを埋め込んでみる - Qiita
概要 ScalaのPlay FrameworkでFormに、hiddenタグをどう埋め込むかについて調べてみた＆試しにサンプルを作成してみました。 前提 Play Framework2.6を前提としているので、Formの基本的な仕様は以前に私が投稿した、Play Framework 2.6(Scala)でFormの処理を作ってみたの内容をご参照ください。 対応方法 How to hide a text field in play frameworkのstackoverflowの記事によるといくつか対応方法はあるようですが、今回のサンプルはinputタグを直接使う方法で試してみました。 サンプルの概要 とあるカテゴリーの登録画面で既存にあるカテゴリーを変更するイメージを前提として、リクエストパラメータで受け取ったIDをFormのhiddenに埋め込むようなサンプルソースにしています。DB接続
scala 2.13で追加された最高にイケてるpipeメソッドの紹介 - Qiita
def superCalculate(): Int = 42 def hyperCalculate(i: Int): Int = i * i def formatCutely(i: Int): String = "♡♡♡♡♡ " + i + " ♡♡♡♡♡" Some(formatCutely(hyperCalculate(superCalculate()))) ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ ここが非常にわかりづらい。どういう意味でわかりづらいかというと処理順番と表記順番が逆である点だ。 処理順番は superCalculate hyperCalculate formatCutely Some であるにも関わらず、コードを読むときは Some formatCutely hyperCalculate superCal
古臭いデータベースに、Scalaで挑む。 - Qiita
昔書いた記事だけど、闇のデータベースが相手なのでアドベントカレンダーにあげておきます。記事には書いてないけどakkaは使っているよ。 序 システム移行などで、先人が作った古臭いデータベースの中身を把握しなければならないことがある。 （私の場合は、かなり古いバージョンのpostgres） こうした場合、psqlなどのSQlコマンドラインツールを使って テーブル一覧を見たり、これは思うテーブルにクエリをかけたりすることになるだろう。 しかし、古臭いデータベースは時として手ごわい。 例えば、本番データとダミーデータとがテーブル上に混在していて、両者をトリッキーな方法で分離しなければならないことなどが次々と起こることがある。加えて、テーブル構造が分かっていないのに個人情報は全て匿名化してくれ、などというげんなりする要求が出てきたりもする。こうした時、SQLだけでは限界があり、やはりプログラム言語の
To create a tiny DataFrame(spark) from a nested List - Qiita
import org.apache.spark.sql._ val spark = SparkSession.builder().master("local").getOrCreate() import spark.implicits._ val values = List(List("A", "3", "3", "4", "3", "3"), List("B", "2", null, "4", "3", "2"), List("B", "1", "3", "5", "1", "5"), List("C", "2", "4", null, "3", "3"), List("C", "3", null, "4", null, "1")). map(x => (x(0), x(1), x(2), x(3), x(4), x(5))) val df = values.toDF("name", "
Akkaことはじめ（２） - Qiita
Akkaを使う上で理解しておくとよいライブラリ、コンポーネントについて紹介します。いろいろあると思いますが、Typesafe Configライブラリ、ルーティング、ストリーミング処理、デプロイツールなどを解説します。 Typesafe Config Scalaでよく使われるコンフィグ設定を読み込むためのライブラリ。src/resourcesフォルダなどのクラスパスに含まれるコンフィグファイルを自動的に読み込んでくれます。公式サイトはこちら。 インポートのためには、build.sbtに以下を入力します。ただし、akka-actorのパッケージにも含まれているようで、その場合は以下の設定は必須ではなようです。 コンフィグファイルの名称は以下にしておく必要があります。起動パラメータで変更できますが、その必要はないでしょう。公式サイトによると、ライブラリやフレームワークの設定はrefarence.
cats.data.Reader使い方メモ - Qiita
trait Repository { type ResultMonad[_] def fetch(): ResultMonad[Int] } class OnMemoryRepository extends Repository { override type ResultMonad[A] = cats.Id[A] override def fetch(): ResultMonad[Int] = 3 // 戻り値は適当 } class RDBRepository extends Repository { type Connection = String // Stringをコネクションだと思ってください… override type ResultMonad[A] = Reader[Connection, A] override def fetch(): ResultMonad[Int] =
Scala の Trait の使用例 - Qiita
目標 Scala の Trait がどううれしいかについて論じます． 注意 Scala の Trait は厳密には Mixin なので，以降の文では Mixin という言葉を使いますが，特に気にしないという人は Mixin のことを Trait に置き換えて読んでください． Mixin の簡単な説明 あるクラスに複数の別のクラスの機能を持たせるために多重継承するとき，もし複数の親クラスが同じ名称のメンバー変数や関数を持つとき，子クラスはこの名称のメンバへアクセスするときにどちらの親クラスのメンバにアクセスすればよいか曖昧になる． Mixin を用いることで，継承の順序関係を明らかにでき，さらに子クラスで Mixin の継承先を決定できるため，継承先のクラスを子クラスが柔軟に決定することができる． 電子マネーのウォレットのような，外部サーバと API を通じて連携するアプリケーションの実装を
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
【Mac用】1行でScala環境構築 - Qiita
