stream

0熱

1答えて

Pythonの、私から、次のようなコードを使用していますtweepyストリーム

：https://github.com/tweepy/tweepy/blob/master/examples/streaming.py APIを使用すると、この例のトラック= [「USA」、「カナダ」]で、複数のフィルタ条件を追跡することができます。これは本質的にストリームが「カナダ」または「アメリカ」のいずれかを指すつぶやきを収集することを意味します。 問題は、on_data（）関数はデータを出

python twitter stream tweepy 2017-12-17

---

0熱

1答えて

Systemdサービス（Pythonループ - > ffmpegストリーム）

なぜこんにちは！初めてのポスター、長い時間の読者。 私はまだ初心者/中間raspbianのユーザー（Debianのストレッチ）と一般的にのpythonんだけど、ここに行くようにこの質問は、私にとっては少し難しいです： 私は現在パイソンスニペット（FIG1）を介しicecast2を通して、ffmpegのでストリームを実行しています。私は実行するためににsystemdサービスを作成したブート（FIG2

python ffmpeg stream debian systemd 2017-12-18

---

0熱

1答えて

GStreamerには即座に終了しますが、私はその場でオーディオとビデオを生成し、RTMPサーバーなど単収縮やYouTubeにストリーミングできるプログラムやロボットを構築しようとしていますコマンドライン

で結構です。私は、Gstreamerを使用してビデオとオーディオのストリームを取り込むことができることを発見しました。また、GstreamerにはPythonでライブラリがあることがわかりました。私のロボットはPythonで既に書かれているからです。 問題であり、testvideosrc入力してテストする場合、私は、コマンドライン上のオーディオとビデオの両方を使用して、コマンドの仕事がうまく作るこ

python python-3.x command-line stream gstreamer 2017-12-19

---

0熱

1答えて

org.springframework.data.redis.serializer.SerializationException

私はredisからデータを読み込むアプリケーションを持っています。私は以下の例外スタックを取得しています org.springframework.data.redis.serializer.SerializationException：デシリアライズできません。ネストされた例外はorg.springframework.core.serializer.support.SerializationFai

stream jedis spring-data-redis 2017-12-19

---

2熱

1答えて

変換バイトストリームが

私は最終的にバイト配列に変換し、キャッシュに書き込まれるに書き込まれた大量のデータを持っているByteArrayOutputStreamは、している：ここで try { ByteArrayOutputStream baos = new ByteArrayOutputStream(); try (JsonGenerator jg = mapper.getFactory().c

java arrays memory stream 2017-12-20

---

0熱

1答えて

フォルダを選択し、特定のファイルタイプを検索し、テキストボックスに肯定的な書き込みを行う場合

特定のファイルタイプを探すプログラムを開発しています。 フォルダを選択し、ファイルのストリームを見つけた場合にファイルタイプをスキャンし、テキストボックスにクエリ結果を書き込みます。これまでのところ、私はそれを知っているが、どのような機能は、私はこの仕事をするために使用する必要があり、 For Each file1 In IO.Directory.GetFiles(folderA, file_A)

vb.net stream folderbrowserdialog 2017-12-20

---

0熱

1答えて

HTTPプロトコルを使用して、HTTPサーバからクライアントへの非同期データストリームの送信を実装する方法はありますか。

一般的なHTTPサーバまたはフレームワークでHTTPプロトコルを使用して、HTTPサーバからHTTPクライアントへの非同期データストリームを実装するにはどうすればよいですか？ （クライアントはブラウザまたは非ブラウザことができる） [client] ----request for data----> [server] [client] <-------xxx------[server] [-

http asynchronous stream http-headers reactive-streams 2017-12-21

---

-1熱

1答えて

カフカのイベント処理確認

カフカで何らかのイベント処理を実現しようとしています。私はカフカのキューにイベントを投稿するプロデューサーをいくつか持っています。また、イベントを取得し、処理し、処理されたデータをDBに保存する消費者もいます。しかし、私はすべてのイベントが処理され終了したことを確認する必要があります。キューから取り出した後にイベントが処理中に突然クラッシュするとどうなりますか？この特定のイベントがまだ処理されてい

java asynchronous stream apache-kafka 2017-12-21

---

-3熱

3答えて

c＃streamWriter WriteLineAsyncを待たずに

StreamWriter行asyncに書きたいと思いますが、私はこれを待たずにいます。 for(int i= 0 ;i<1000;i++) { sw.WriteLineAsync(i.ToString()); } しかし、私はWriteLineAsyncに同時に呼び出すというエラーが発生しました。 これを修正するにはどうすればよいですか？ このループの後にこれを閉じたいとします。

c# asynchronous stream async-await 2017-12-25

---

0熱

2答えて

ストリームを反復する

私はScalaにとって新しく、範囲[i; j]の数値の素数を見つけなければなりません。 val stream = (i to j).toStream 、その後、私は素数を見つけることになって、この関数を呼び出す：例外なぜ私は取得していますストリームを出力 def findPrimes(s: Stream[Int]): Stream[Int] = { println("HEAD: "

scala stream 2017-12-27

---