파일 목록이 있습니다. 내가 원한다 : 모두를 단일 소스로 읽는 것. 파일을 순차적으로 순서대로 읽어야합니다. (라운드 로빈 없음) 어떤 파일도 전체적으로 메모리에 있어야합니다. 파일을 읽는 중 오류가 발생하면 스트림이 접혀 있어야합니다. 그것은 작동합니다 같은 느낌 : (스칼라, akka - 스트림 v2.4.7)를 val sources = Seq("fil
각 줄을 처리하기 위해 akka 스트림을 사용하여 여러 개의 큰 파일을 읽고 싶습니다. 각 키가 ("식별자"-> "값")으로 구성된다고 상상해보십시오. 새로운 "식별자"가 발견되면 데이터베이스에 저장하고 "값"을 저장하려고합니다. 그렇지 않으면 식별자가 이미 스트림 스트림을 처리하는 동안 발견 된 경우 "값"만 저장하려고합니다. 이를 위해 이미 맵에서 발견
그래프를 동적으로 변경하는 대신 어떤 방법을 사용할 수 있습니까? 여기에 내 상황이있다. DB에 기사를 수집하는 그래프가 있습니다. 기사는 다른 형식의 3 가지 플러그인에서 제공됩니다. 따라서 나는 몇 흐름 val converterFlow1: Flow[ImpArticle, Article, NotUsed]
val converterFlow2: Flow[New
단일 요소 뒤에 내 akka 스트림이 중지됩니다. val firehoseSource = Source.actorPublisher[FirehoseActor.RawTweet](
FirehoseActor.props(
auth = ...
)
)
val ref = Flow[FirehoseActor.RawTweet]
.map(r => Re
나는 CQRS Akka 배우 앱의 질의면을하고 있습니다. 쿼리 배우는 클러스터 샤드로 설정되며 하나의 지속성 쿼리 스트림의 이벤트로 채워집니다. 내 질문은 : 클러스터 파편에있는 배우 중 하나가 그것을 복구하는 방법을 다시 시작하면? 전체 클러스터 샤드를 종료하고 모든 이벤트에 응답 하시겠습니까? 클러스터 샤드에있는 액터를 영속 액터로 만들고 쿼리 측에만
배우에게 간단한 GET on GET 서비스를 호출하려고합니다. 그 때문에 나는 akka-http-experimental_2.11과 akka-http-jackson-experimental_2.11을 사용하고 있습니다. 내가 이해할 수있는대로 시도해보십시오 java 예제. 호출은 비동기로 만들어지고 응답은 POJO에 매핑됩니다. 도와 주시겠습니까? 나는 Sin
akka-http를 이와 같이 사용하는 것은 학대입니까 또는 위험한 일입니까? 클라이언트 측에서 다음 def source(consumerOffset: UUID) =
readJournal.eventsByTag(“MyTag", consumerOffset).map(_.asJson)
pathPrefix("stream"/Segment.map(UUID.f
저는 akka-http 및 akka-streams을 사용하여 실제 websocket 응용 프로그램을 구현하는 가장 좋은 방법을 찾으려고합니다. 내가 주로 찾고있는 것은 단순성이다. 나는 지금 그저 얻지 못하고있다. 여러 요청을 구분할 필요가있는 상당히 복잡한 파이프 라인이 있고 처리를 위해 액터로 요청을 보내거나, 때때로 문고 쿼리를 실행하고 응답을 반환하
akka stream vs spark stream을 스트림 처리에 사용하는 장점/단점은 무엇입니까? 다시 압력, 성능, 내결함성, 변형, 유연성 등을 기본으로 만들어졌습니다. 저는 akka vs spark pros/cont를 엄격하게 스트리밍하는 구성 요소를 요구하지 않습니다. 또한 후드 프레임 워크 아키텍처 차이점을 묻지도 않습니다.
나는 n의 Akka-stream 흐름 이후에 하나의 결과를 가져와 요청을해야하는 유스 케이스가 있습니다. HTTP REST API에 연결합니다. HTTP 요청하기 전에 마지막 akka 스트림 흐름 유형, 문자열입니다 : 다음 val stream2: Flow[String,Future[HttpRespone],NotUsed] = Flow[String].map(p