amazon-kinesis

0열

2답변

node.js를 사용하는 람다에서 어떻게 kinesis 스트림의 데이터를 파싱 할 수 있습니까?

kinesis를 이벤트 소스로 설정 한 다음 람다 함수가 있습니다. 데이터가 스트림으로 전달됩니다. 여기에서이를 파싱하여 문자열로 처리합니다. {id=2, sourceIp=220.220.1.220 }. 이것을 node.js의 객체로 변환하고 싶습니다. 어떻게해야합니까? exports.handler = (event, context) => { eve

0열

2답변

AWS의 문제점 Firehose 중간 S3 버킷 및 전달 스트림 종속성

여러 전달 스트림에 대해 하나의 s3 버킷을 설정하는 것이 좋습니다. (예 : 서로 다른 스트리밍 처리량, s3 버퍼 크기/버퍼 간격을 갖는 두 개의 전달 스트림을 고려하십시오.) 두 개의 전달 스트림 (S1, S2)이 데이터를 적색 변이로 라우팅하는 경우. S1은 T1에 데이터를 전달하고 S2는 T2로 데이터를 전달합니다. T2에는 T1에 외래 키 제약

0열

1답변

웹 서비스 용 AWS Kinesis

내 고객 중 한 명이 제 3 자 서비스에서 데이터를 읽는 기존 애플리케이션을 가지고 있으며, 내 데이터베이스에 쓰십시오. 나중에이 데이터는 내 안드로이드 앱에 웹 서비스를 만드는 데 사용됩니다. 이제 전체 코드가 AWS로 마이그레이션되고 고객이 더 나은 서비스를 원합니다. 그래서 조사에서 AWS 서비스 "Kinesis"가 데이터 스트리밍에 사용될 수 있음을

3열

1답변

API 게이트웨이의 본문에 JSON 객체를 Kinesis 프록시에 추가 하시겠습니까?

Kinesis 스트림에 기록을 넣기 위해 Amazon’s tutorial에 설명 된대로 Kinesis 프록시로 API 게이트웨이를 구성했습니다. 통합 요청에 대한 HTTP 헤더는 다음과 같습니다 stream-name 이 application/x-amz-json-1.1 바디 매핑 템플릿에 매핑되는 method.request.header.partition-ke

0열

1답변

Amazon Web Services Kinesis, EMR 및 S3 on cloud

여러 개의 Windows 장치에서 CSV 데이터를 전송해야하는 사용 사례가 있습니다. 사용 시간은 말합니다. 타겟 사용 시간이 예 : 총 80 시간. 이제 각 PC는 키네 시스 스트림을 통해 사용량을 전송할 것이며 EMR을 사용하는 클라우드에서 적용 범위를 업데이트 할 것입니다. PC1 ~ 10 시간, PC2 ~ 20 시간, PC3 ~ 5 시간, PC4 ~

0열

2답변

Kinesis lambda DynamoDB

유스 케이스에 대한 AWS 서비스를 배우고 있습니다. 문서를 살펴본 후 간단한 흐름을 보았습니다. Streams API와 KPL을 사용하여 Kinesis 스트림에 데이터를 가져 오려고합니다. 예제 putRecord 메서드를 사용하여 스트림에 데이터를 수집합니다. {"userid":1234,"username":"jDoe","firstname":"John","

2열

1답변

AWS Kinesis 과거에서 읽음

AWS Kinesis 스트림에서 시간을 거슬러 읽는 방법은 무엇입니까? AWS Kinesis 스트림을 사용하면 이벤트 스트림을 보내고 소비자 응용 프로그램은 이벤트를 읽을 수 있습니다. Kinesis Stream 작업자가 레코드를 가져 와서 마지막 체크 포인트에서 IRecordProcessor # processRecords으로 전달합니다. 그러나 2 시간

1열

1답변

AWS 람다를 사용하여 Kinesis를 읽고 S3에 저장

AWS를 처음 접했습니다. 이제 aws .net sdk를 사용하여 키네시스 스트림으로 CSV 데이터를 보낼 수 있습니다. 이제 S3 에미 터를 사용하여 람다를 사용하여 S3에서이 데이터를 저장해야합니다 (많은 웹 사이트에서 가장 많이 사용되는 방법입니다). 내가 그것을위한 람다 함수를 만들 때. Node.js 또는 java8 코드를 묻습니다. 여기에서 어떤

0열

1답변

kinesis 에이전트 람다, 기원 파일 및 서버를 얻는 방법

나는 kinesis 스트림에 많은 로그 파일 정보를 스트리밍하는 Kinesis 에이전트가 있으며 정보를 구문 분석하는 람다 함수가 있습니다. 람다에 문자열 이외에도 소스 파일 이름을 알 필요가있는 컴퓨터 이름이 가능합니까?

0열

1답변

Kinesis PUT 한도, 정확히 무엇을 의미합니까?

아마존 주장 키네시 스 스트림은 "without limits"이지만 "you should keep in mind"은 "각 샤드는 초당 1000PUT 레코드를 지원할 수 있습니다"라고 말합니다. 이는 스트림 당 초당 1000 개의 메시지를 처리 할 수 없다는 것을 의미합니까? 번호를 초과하면 메시지가 손실됩니까?