stream

1열

1답변

왜 여러 스트림에서 반복하는 것은 첫 번째 요소를 반복하는 것입니까?

최근에 여러 스트림을 반복하여 첫 번째 항목을 통해서만 반복하도록하는 코드에서 버그가 발생했습니다. 스트림을 버퍼로 변환했다. (함수의 구현이 스트림을 리턴한다는 사실조차 알지 못했다.) 문제가 수정되었다. I는 판단이 어려운 발견 그래서 최소 검증 예 생성 : def f(as: Seq[String], bs: Seq[String]): Unit =

scala stream 2017-12-15

---

0열

1답변

Nodejs에서 다중 스트림을 처리하는 방법은 무엇입니까?

나는 이미지 조작의 서비스를 쓰고 있어요 나는 여러 크기 const writable1 = storage(name1).writableStream(); const writable2 = storage(name2).writableStream(); const writable3 = storage(name3).writableStream(); //piping th

node.js stream concat 2017-12-15

---

2열

1답변

파이썬 gRPC로 스트리밍 메시지를 처리하는 방법

나는이 메시지를 따르고있다. Route_Guide sample. 해당 샘플이 발생하고 특정 메시지에 회신하지 않고 메시지를 읽습니다. 후자는 제가 성취하려고하는 것입니다. 여기 내가 지금까지이 작업은 다음과 같습니다 import grpc ... channel = grpc.insecure_channel(conn_str) try: grpc.ch

python stream grpc 2017-12-15

---

0열

1답변

파이썬, 난에서 아래와 같은 코드를 사용하고 tweepy 스트림

: https://github.com/tweepy/tweepy/blob/master/examples/streaming.py API는이 예제 트랙 = [ '미국', '캐나다']에 여러 필터 조건을 추적 할 수 있습니다. 이것은 기본적으로 스트림이 '캐나다'또는 '미국'을 언급하는 트윗을 수집한다는 것을 의미합니다. on_data() 함수는 데이터를 인쇄하지만

python twitter stream tweepy 2017-12-17

---

0열

1답변

Systemd 서비스 (파이썬 루프 -> ffmpeg 스트림)

안녕하세요! 처음 포스터, 오랜 시간 독자. 나는 : 나는 아직도 raspbian (데비안 스트레치) 및 일반 파이썬의 초급/중급 사용자 해요,하지만 여기 간다 이 질문은, 나를 위해 조금 어렵다 현재 파이썬 조각 (, 필립스)를 통해 icecast2을 통해, 는 FFmpeg로 스트림을 실행. 내가 실행하는 systemd 서비스를 만든 부팅 (그림 2)에

python ffmpeg stream debian systemd 2017-12-18

---

0열

1답변

Python의 Gstreamer는 즉시 종료되지만 명령 줄에서는 정상적으로 작동합니다.

즉석에서 오디오와 비디오를 생성하고 트 위치 나 유튜브와 같은 rtmp 서버로 스트리밍 할 수있는 프로그램이나 로봇을 만들려고합니다. Gstreamer를 사용하여 비디오 및 오디오 스트림을 가져올 수 있음을 발견했습니다. 나는 또한 Gstreamer가 Python으로 라이브러리를 가지고있는 것을 발견했다. 나의 로봇은 이미 파이썬으로 작성 되었기 때문에 좋

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.Serializatio

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

---

0열

3답변

node.js 버퍼를 문자열로 변환 한 다음 JSON으로 변환

버퍼를 내보내고 toString() 함수를 사용하여 node.js readstream을 사용하여 버퍼를 문자열로 변환 한 다음 문자열을 JSON으로 변환하려고 시도합니다. JSON.parse() 함수를 통해 구문 분석 오류가 발생합니다. 버퍼를 문자열로 변환 한 다음 해당 문자열을 JSON으로 변환하는 가장 좋은 방법이 있습니까? JSON 문자열은 다음과

javascript node.js stream buffer 2017-12-21

---

-1열

1답변

카프카에서 이벤트 처리 확인

카프카에서 일종의 이벤트 처리를 구현하려고합니다. 카프카 대기열에 이벤트를 게시하는 프로듀서가 있습니다. 또한 이벤트를 가져 와서 처리하고 처리 된 데이터를 DB에 저장하는 소비자도 있습니다. 그러나 모든 이벤트가 처리되고 완료되었는지 확인해야합니다. 대기열에서 이벤트를 가져온 후 이벤트가 예상치 않게 갑자기 중단되는 경우 어떻게해야합니까? 이 특정 이벤트

java asynchronous stream apache-kafka 2017-12-21

---

0열

2답변

스트림을 통해 반복하기

저는 스칼라에 대해 매우 새롭기 때문에 범위 [i; j]의 숫자에 대한 소수를 찾아야합니다. val stream = (i to j).toStream 다음 나는 소수를 찾는 가정이 함수를 호출 : 예외 이유는 무엇입니까 스트림을 출력하기 def findPrimes(s: Stream[Int]): Stream[Int] = { println("HEAD

scala stream 2017-12-27

---