amazon-kinesis

1열

2답변

우리는 다음과 같은 시험을 여러 번 수행, 우리는 이런 일이있을 수있는 이유에 대해 합리적인 설명 찾기 위해 투쟁 : 우리는 소비자를 만들 이 될 수 있도록, 우리는 기다립니다 준비는 우리는 소비자가 우리는 하나 개의 파편을 가지고 인식하고있는 스트림에 두 개의 레코드를 게시하고, 때로는 소비자는 기록 통보되지 않습니다. 다른 workerId를 사용하지만

2열

2답변

람다 API 게이트웨이 VS 운동성 스트림에서

배경 내가 AWS의 운동성, API 게이트웨이에 대해 공부하고 있습니다. 요청이 API 게이트웨이를 공격 할 때마다 데이터를 스트림으로 전달할 수 있거나 람다를 트리거하도록 선택할 수 있다는 점을 이해합니다 (일부 처리). 내가 직접 API 게이트웨이에서 람다 (요청이 도착하면, 그것은 실시간입니다) 트리거 할 수있는 경우 생각과 쿼리 그래서, 내 생각은,

0열

2답변

Kinesis 스트림에 대한 DynamoDB

DynamoDB 테이블에 쓰는 응용 프로그램이 있는데 Kinesis에서 내 집계를 수행 한 다음 집계 된 데이터를 다른 DynamoDB 테이블에 기록하려고합니다. 스트림은 내 DynamoDB의 테이블 활성화, 다음과 같이 내가 스트림에 Lamdba 트리거를 가지고있다 : 나는 람다 테스트 이벤트에서 세 가지 또는 네 가지 요소가있을 때 'use strict

0열

1답변

아마존 키네시스 분석에 대한 마케팅 자료를 살펴보면 실시간 로그 분석 흐름을 살펴보고 있고, 콘텐츠 제안을 위해 Amazon ES에 데이터가 파이프되는 네 번째 단계가 있습니다. 아마존 ES는 무엇 입니까? 그것은 그들의 탄력적 인 검색 서비스입니까? 그렇다면 맞춤 검색은 탄력적 검색으로 어떻게 생성됩니까?

0열

2답변

Spark Streaming Kinesis 통합 : LeaseCoordinator를 초기화하는 중 오류가 발생했습니다.

kinesis 응용 프로그램을 사용하여 간단한 바닐라 스파크 스트리밍을 실행할 때 몇 가지 문제가있었습니다. 일부 지침서에서는 기본 안내를 Snowplow 및 WordCountASL으로 따랐습니다. 그러나 나는 아직도이 때문에 운동성 작업자 오류로 작동 할 수 없습니다 : 여기 16/11/15 09:00:27 ERROR Worker: Caught excep

0열

1답변

로컬 Sqlite 데이터를 kinesis 스트림과 동기화합니다.

sqlite DB에 데이터를 저장하는 안드로이드 앱을 개발 중입니다. Kinesis 스트림을 업데이트 할 예정이지만, 네트워크가 없으면 이전 데이터를 kinesis로 관리 할 수 없습니다. 나는 인터넷 연결이되면 내 데이터를 동기화하는 kinesis 스트림과 sqlite DB를 동기화하는 방법이 있는지 알고 싶습니까?

0열

1답변

일련의 키네 시스 스트림과 람다 (lambda)에 대한 종단 간 시간 계산

입력 레코드를 가져 와서 일련의 키네 시스 스트림과 람다를 사용하여 일련의 변환을 적용하는 시스템이 있습니다. 는 KinesisStream ->은 InputRecord -> Lambda1/Lambda2 병렬 실행 -> 출력 1 운동성 스트림 -> Lambda3 -> 출력 2 운동성 스트림 - DynamoDB의으로> 저장소 는 http://docs.aws.a

0열

1답변

Firehose를 사용하는 Kinesis Stream to S3 백업

고객 트랜잭션이 포함 된 AWS Kinesis Stream을 사용하고 있습니다. 처리를 시작하기 전에 S3로 트랜잭션을 백업하고 싶습니다. Kinesis Firehose를 사용하여 Kinesis Stream에서 람다 또는 다른 컴퓨팅 구성 요소를 실행하지 않고 트랜잭션을 백업하려면 어떻게해야합니까?

0열

1답변

Kinesis 읽기 실패 일부 레코드

메트릭 GetRecord.success은 일정 기간 동안 0 값을 표시합니다. 그것은 일부 기록이 키네시스에서 읽히지 않는다는 것을 의미합니까? 그래도 ReadProvisionedThroughputExceeded 값은 0입니다.

5열

1답변

DynamoDB 스트림의 전파 대기 시간은 어떻게 측정 할 수 있습니까?

DynamoDB Streams + Kinesis 클라이언트 라이브러리 (KCL)를 사용하고 있습니다. 이벤트가 스트림에서 생성 된 시점과 KCL 측에서 처리 된 시점 간의 대기 시간을 측정하려면 어떻게해야합니까? 아시다시피 KCL의 MillisBehindLatest 메트릭은 Kinesis Stream (DynamoDB 스트림 제외)에만 해당됩니다. appr