Kafka StreamsのWindowStateStoreを利用した集計処理で未来のタイムスタンプを扱う際の危険な罠
Kafka StreamsにはWindow Aggregationという仕組みがある。 特定の時間間隔毎にイベントの数を数えたり等を行うための機能だ。 で、それを利用してユーザー毎のイベント実行...
106 search resultsShowing 1~20 results
Kafka StreamsにはWindow Aggregationという仕組みがある。 特定の時間間隔毎にイベントの数を数えたり等を行うための機能だ。 で、それを利用してユーザー毎のイベント実行...
AWSの新しいロードバランサであるNLB(Network Load Balancer)を使ってfluentdのforwardパケットを分散してみたので、レポートをまとめておく。 NLB自体につい...
設定ファイルとしてYAMLを扱うことが多いため、yamlを便利に扱うためにyaml_vaultとyaml_masterというgemを作っている。 yaml_vaultはYAMLの特定キーを暗号化...
ある時間になったらジョブを起動するスケジューラを実装したgemは、世の中に色々とあります。 javan/whenever: Cron jobs in Ruby adamwiggins/clock...
最近はneovimを使っている。neovim-qtが割と安定していて良い。 neotermとvim-testでテストを実行する。 direnv等で、プロジェクト毎に環境変数を指定し環境変数でコン...
できるだけproductionに近い状態でAWSの各コンポーネントと通信したり、DBのデータを取得できる環境で、アプリケーションの動作確認をしたいことがある。 共有の開発者用のステージング環境等...
この記事は、大江戸Ruby会議06で発表した Docker時代の分散RSpec環境の作り方 // Speaker Deck の補足です。 何人かに質問されたことや、良いことばかりじゃなくて現状存...
最近、Rails界隈でDocker使い始めました、という話を聞く機会が増えてきたので、自分が開発環境整備用に構築したDockerの設定をまとめておく。 ちなみに、production運用について...
ECS optimized AMIはAmazon LinuxでDockerを動かす様になっている。 Amazon LinuxのDockerはデフォルトでdevice mapperをストレージのバ...
最近、手元でRSpecを全部流すなんてことはあんまり無くなってきた。 CIサービス上で結果は確認できても、色々情報を収集したり加工したりしたい場合ローカルのファイルシステムに吐くより、S3とかG...
基本的にassetsファイル系はクラウドなりCDNに上げてるはずで、dockerイメージの中にそんなものを含めたくはないわけですよ。 しかし、未だにsprocketsという世界から抜け出ることは...
ちなみに、最初に結論だけ言っておくと、まずSandi Metzの「オブジェクト指向設計実践ガイド」を読め、という話です それだけで終わってしまいたい気持ちはあるが、不親切過ぎるしもうちょっとRa...
Bigqueryはしばらく前から、AVROフォーマットでデータをエクスポートできるようになっています。 AVROフォーマットは、Apacheプロジェクトの一つとして開発されているシリアライズフォ...
スマートな方法が思い付かなかったのでシェルスクリプトでラップするという雜な手段を取った。 # !/bin/zsh set -e container_name="container_app_1" ...
2014/11/12時点での話で、これからどうなるか分からないのですが、現時点のrails-4.2.0.beta4では、Arelを使ったORクエリの構築を今までと同じ感覚で実行するとNoMeth...
あんまりEC2ノードごと増やしたり減らしたりってのは、やらないで済むに越したことはないんですが、お金に限りがある世界では、無駄に何十台もサーバー立ててられないので、適宜減らしたりしたいわけです。...
Amazon ECSはコンテナの管理をしてくれるサービスという体になってますが、実際には普通のEC2インスタンスの上で動作します。 コンピューティングリソースは、基本的にEC2のAuto Sca...
以前、yaml_vault というyamlで書いた設定ファイルを暗号化するgemを作りました。 そのyaml_vaultでAWS KMSを利用した暗号化をサポートしました。 AWS KMSで作っ...
最近、仕事が忙しくて、小物のgemを作るというoutputが無かったので、思い付いたものを無理矢理形にしてみた。 タイトル通りで、キーワード引数で受け取った値をHashとしてまとめて取得するge...
EMRでembulkのmapreduce executorを動かすまでに割と苦労したのでメモっておく。 そもそもあんまHadoopエコシステムに詳しくないし、Javaにも詳しくない。 そして、余...
106 search resultsShowing 1~20 results
Qiita is a knowledge sharing service for engineers.