問題タブ [amazon-kinesis]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
amazon-web-services - Amazon Kinesis エミュレーター
リアルタイムのイベント処理エンジン (twitter の嵐など) を評価しています。オプションの 1 つは、最近リリースされたAmazon Kinesisです。
AWSアカウントをセットアップしてサービスの使用料を支払う必要なしに、キネシスを少しいじることができるエミュレータ/サンドボックス環境が利用できるかどうか疑問に思っています.
前もって感謝します
amazon-web-services - Apache Camel を Amazon Kinesis Streaming Service に統合する
Apache Camel を Amazon Kinesis Streaming Service に統合した人はいますか?
これは、 Apache Camel と統合されている他の Amazon サービスに関する質問を含むAmazon AWS での Apache Camel の使用に関連しています。
私は、Amazon Kinesis エンドポイントが開発中であるか、何らかの早期採用の形で存在することを望んでいました。
ありがとう。
PS。「評判」ポイントが多い人は、この投稿に amazon-kinesis タグを追加できますか? ;-)
ruby-on-rails - AWSキネシスにデータを記録するファットレールアプリ?
nfs共有を介して多数のec2インスタンスで実行するこのファットRailsアプリがあります。このため、ログ ファイルが詰まってしまうので、発生した例外やエラー、その他のいくつかのことを表示できるようにしたいと考えています。
これを行う方法はありますか?
scala - Kinesis (Amazon AWS) への送信時に Scala Futures が実行されない
アプリケーションの負荷テストを行えるように、Scala Futures を使用して Amazon Kinesis に非同期でメッセージを書き込もうとしています。
このコードは機能し、データがパイプラインを下って移動し、出力がコンソールに表示されることを確認できます。
このコードは Scala Futures で動作します。
構文はシーケンスのマッピングとほぼ同じであることに注意してください。ただし、次の方法は機能しません (つまり、コンソールに出力することも、パイプラインにデータを送信することもありません)。
このプロジェクトに関するその他のメモ。私は Maven を使用して (コマンド ラインから) ビルドを行っており、上記のすべてのコードを (コマンド ラインからも) 実行するとうまくいきます。
私の質問は次のとおりです。同じ構文を使用すると、関数「send」が実行されていないように見えるのはなぜですか?
log4j - Log4J Baigaizeva で Kinesis を使用する方法
Log4J で Amazon Kinesis を使用したいと考えています。参照できるサンプル コードはありますか?
node.js - Amazon Kinesis NodeJS - putRecord アクションの有効期限が切れる
NodeJS とExpressをプロキシとして使用して、HTTP GET リクエストを処理し、データを少し調整して、Amazone Kinesis にデータを送信しています。これが私のコードからの抜粋です:
200 人の同時ユーザー (ループ 100 回) に対して JMeter テストを実行した後、5 分後に次のエラーが発生します。
10)\n Request.emit (/Users/me/proxy/node_modules/aws-sdk/lib/request.js:578:14) で\n Request.transition (/Users/me/proxy/node_modules/aws- sdk/lib/request.js:12:12)\n AcceptorStateMachine.runTo (/Users/me/proxy/node_modules/aws-sdk/lib/state_machine.js:14:12) で\n /Users/me/ proxy/node_modules/aws-sdk/lib/state_machine.js:26:10\n at Request. (/Users/me/proxy/node_modules/aws-sdk/lib/request.js:28:9)\n リクエストで。(/Users/me/proxy/node_modules/aws-sdk/lib/request.js:580:12)\n Request.callListeners (/Users/me/proxy/node_modules/aws-sdk/lib/sequential_executor.js: 90:20)」runTo (/Users/me/proxy/node_modules/aws-sdk/lib/state_machine.js:14:12)\n at /Users/me/proxy/node_modules/aws-sdk/lib/state_machine.js:26:10 \n ご要望に応じます。(/Users/me/proxy/node_modules/aws-sdk/lib/request.js:28:9)\n リクエストで。(/Users/me/proxy/node_modules/aws-sdk/lib/request.js:580:12)\n Request.callListeners (/Users/me/proxy/node_modules/aws-sdk/lib/sequential_executor.js: 90:20)」runTo (/Users/me/proxy/node_modules/aws-sdk/lib/state_machine.js:14:12)\n at /Users/me/proxy/node_modules/aws-sdk/lib/state_machine.js:26:10 \n ご要望に応じます。(/Users/me/proxy/node_modules/aws-sdk/lib/request.js:28:9)\n リクエストで。(/Users/me/proxy/node_modules/aws-sdk/lib/request.js:580:12)\n Request.callListeners (/Users/me/proxy/node_modules/aws-sdk/lib/sequential_executor.js: 90:20)」
すべての Kinesis レコードが確実に送信および保存されるようにするためにできること (構成またはコードの変更) はありますか?