alpakka

2열

1답변

나는 Alpakka-FTP을 사용하고 있지만 어쩌면 나는 일반적인 akka-stream 패턴을 찾고있다. 는 FTP 커넥터 파일을 나열하거나 검색 할 수 있습니다 def ls(host: String): Source[FtpFile, NotUsed] def fromPath(host: String, path: Path): Source[ByteString, Fu

1열

1답변

Alpakka - S3에서 Kryo 직렬화 된 객체를 읽습니다.

S3 (수천 개의 직렬화 된 객체)에 Kryo 직렬화 된 이진 데이터를 저장했습니다. Alpakka은 data: Source[ByteString, NotUsed]으로 내용을 읽을 수 있습니다. 그러나 Kryo 형식에서는 구분 기호가 사용되지 않으므로 data.via(Framing.delimiter(...))을 사용하여 각 직렬화 된 개체를 ByteStrin

0열

1답변

alpakka 슬릭 커넥터를 사용하여 mysql에 case 객체를 삽입하는 방법

MySQL에 데이터를 삽입하는 코드를 작성 중입니다. 나는 Alpakka Slick Connector를 사용하기로 결정했습니다. 해당 예제 사용 : https://developer.lightbend.com/docs/alpakka/latest/slick.html#using-a-slick-flow-or-sink DB에 데이터를 성공적으로 추가했지만 SQL 명령

0열

1답변

Alpakka JMS 거래

나는 Oracle AQ에서 데이터를 대기열에서 제외하기 위해 Alpakka 및 그 JMS 커넥터로 게임을하고 있습니다. 아래의 매우 기본적인 구현 방법을 따라 가면 this 가이드가 될 수 있습니다. 제 질문은 어떻게 처리 할 수 있습니까? 예외가 발생하면 내 메시지가 손실되지 않도록 보장 할 수 있습니다. 이 PL/SQL 인 경우 object Cons

0열

1답변

배우/에이전트 시스템이 iPaaS를 이중화합니까?

내가 Akka를 (아마 Alpakka 및/또는 Lagom과 함께) 사용하는 응용 프로그램을 가지고 있다고 가정 해 봅시다. Red Hat JBoss 퓨즈와 같은 iPaaS를 계속 사용할 수 있습니까? 그렇다면 이점은 무엇입니까? 그렇지 않다면, iPaaS의 대안 인 배우 시스템의 일부라고 어떻게 부릅니까?

0열

1답변

Alpakka - 메시지 처리시 콜백

각 메시지가 JMS로 성공적으로 전송되거나 실패 할 경우 콜백을 수행하는 방법은 무엇입니까? val jmsSink = JmsSink.textSink( JmsSinkSettings(connectionFactory).withQueue("My_Queue") ) Source(Stream.from(1)) .map(_.toString) .

1열

1답변

DTO를 Alpakka Cassandra에 저장하십시오.

안녕하세요 저는 datastax 드라이버를 사용하여 내 자신의 Cassandra 커넥터를 만듭니다. 하지만 메모리 누출 문제가 있으므로 Cassandra 커넥터가있는 Alpakka de lightbend와 같은 다른 솔루션을 고려하기 시작합니다. 하지만 가난한 문서를 확인한 후에는 CQLSH 쿼리와 함께 커넥터를 사용하고 있으므로 내 마음이 바뀌었고 제 경

1열

1답변

Akka Streams Alpakka jms의 KickSwitch

alpakka를 사용하여 여러 jmsSource (다른 대기열에 대해)를 시작하는 시나리오가 있습니다. 또한 어느 시점에서든 대기열을 분리해야합니다. 그래서 아래와 같이 jms akka 스트림에 KillSwitch를 추가했습니다. - .. 등등. 응용 프로그램을 시작한 후에 모든 대기열이 연결되어 정상적으로 작동합니다. 그러나 stop 메소드를 사용하여 큐

0열

1답변

왜 Akka Streams 응용 프로그램이 정상적으로 종료되지 않습니까?

나는이 응용 프로그램이 정확히 화면에 10 개의 행을 인쇄 예상 실행되는 Alpakka 카산드라 도서관 package com.abhi import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, ClosedShape} import akka.stream.alpakka.cassandra.sc

0열

1답변

Alpakka 카산드라 흐름 사용

나는 그것은 매우 쉽게 소스와 싱크 카산드라를 사용할 수있게 Alpakka 카산드라 here 의 문서를 읽고있다. 그러나 흐름 사용은 어떻습니까? 흐름을 사용하여 나는 카산드라를 소스 또는 싱크대로 사용하지 않는다는 것을 의미합니다. 그러나 데이터 조회. 은 Alpakka를 사용하여 가능합니까? 또는 직접 Cassandra jdbc 코드를 작성해야합니까?