เดนเต เดนเดฌเตผ!
เดจเดฟเดเตเดเตพเดเตเดเต เดชเดฑเดเตเดเตเดจเตเดจ เดตเดฟเดฎเดพเดจเดเตเดเตพ เดเดทเตเดเดฎเดพเดฃเต? เดเดจเดฟเดเตเดเดฟเดคเต เดเดทเตโเดเดฎเดพเดฃเต, เดชเดเตเดทเต เดธเตเดตเดฏเด เดเดฑเตเดฑเดชเตเดชเตเดเตเดฎเตเดชเตเตพ, เด เดฑเดฟเดฏเดชเตเดชเตเดเตเดจเตเดจ เดเดฐเต เดฑเดฟเดธเตเดดเตโเดธเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดเดฏเตผ เดเดฟเดเตเดเดฑเตเดฑเตเดเดณเตเดเตเดเตเดฑเดฟเดเตเดเตเดณเตเดณ เดกเดพเดฑเตเดฑ เดตเดฟเดถเดเดฒเดจเด เดเตเดฏเตเดฏเตเดจเตเดจเดคเดฟเดฒเตเด เดเดพเตป เดชเตเดฐเดฃเดฏเดคเตเดคเดฟเดฒเดพเดฏเดฟ - Aviasales.
เดเดจเตเดจเต เดเดเตเดเตพ Amazon Kinesis-เดจเตเดฑเต เดชเตเดฐเดตเตผเดคเตเดคเดจเด เดตเดฟเดถเดเดฒเดจเด เดเตเดฏเตเดฏเตเด, เดคเดคเตเดธเดฎเดฏ เด เดจเดฒเดฟเดฑเตเดฑเดฟเดเตโเดธเต เดเดชเดฏเตเดเดฟเดเตเดเต เดเดฐเต เดธเตเดเตเดฐเตเดฎเดฟเดเดเต เดธเดฟเดธเตเดฑเตเดฑเด เดจเดฟเตผเดฎเตเดฎเดฟเดเตเดเตเด, เดชเตเดฐเดงเดพเดจ เดกเดพเดฑเตเดฑ เดธเดเดญเดฐเดฃเดฎเดพเดฏเดฟ Amazon DynamoDB NoSQL เดกเดพเดฑเตเดฑเดพเดฌเตเดธเต เดเตปเดธเตเดฑเตเดฑเดพเตพ เดเตเดฏเตเดฏเตเด, เดฐเดธเดเดฐเดฎเดพเดฏ เดเดฟเดเตเดเดฑเตเดฑเตเดเตพเดเตเดเดพเดฏเดฟ SMS เด เดฑเดฟเดฏเดฟเดชเตเดชเตเดเตพ เดธเดเตเดเตเดเดฐเดฟเดเตเดเตเด.
เดเดฒเตเดฒเดพ เดตเดฟเดถเดฆเดพเดเดถเดเตเดเดณเตเด เดตเตเดเตเดเดฟเดเตเดเตเดฑเดเตเดเดฟเดฐเดฟเดเตเดเตเดจเตเดจเต! เดชเตเดเต!
เดเดฎเตเดเด
เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต, เดเดเตเดเตพเดเตเดเต เดเดเตเดธเดธเต เดเดตเดถเตเดฏเดฎเดพเดฃเต
เด เดฒเตเดเดจเดคเตเดคเดฟเดจเตเดฑเต เดชเตเดฐเดงเดพเดจ เดฒเดเตเดทเตเดฏเด AWS-เตฝ เดตเดฟเดตเดฐ เดธเตเดเตเดฐเตเดฎเดฟเดเดเดฟเดจเตเดฑเต เดเดชเดฏเตเดเดคเตเดคเตเดเตเดเตเดฑเดฟเดเตเดเต เดชเตเดคเตเดตเดพเดฏ เดเดฐเต เดงเดพเดฐเดฃ เดจเตฝเดเตเด เดเดจเตเดจเดคเดพเดฃเต; เดเดชเดฏเตเดเดฟเดเตเด API เดจเตฝเดเตเดจเตเดจ เดกเดพเดฑเตเดฑ เดเตผเดถเดจเดฎเดพเดฏเดฟ เดเดพเดฒเดฟเดเดฎเดฒเตเดฒเตเดจเตเดจเตเด เดเดพเดทเตเดฏเดฟเตฝ เดจเดฟเดจเตเดจเต เดเตเดฎเดพเดฑเตเดฑเด เดเตเดฏเตเดฏเดชเตเดชเตเดเตเดจเตเดจเตเดตเตเดจเตเดจเตเด เดเดเตเดเตพ เดเดฃเดเตเดเดฟเดฒเตเดเตเดเตเดเตเดจเตเดจเต. เดเดดเดฟเดเตเด 48 เดฎเดฃเดฟเดเตเดเตเดฑเดพเดฏเดฟ Aviasales.ru, Jetradar.com เดธเตเดฑเตเดฑเตเดเดณเตเดเต เดเดชเดฏเตเดเตเดคเดพเดเตเดเตพ เดจเดเดคเตเดคเดฟเดฏ เดคเดฟเดฐเดฏเดฒเตเดเดณเต เด เดเดฟเดธเตเดฅเดพเดจเดฎเดพเดเตเดเดฟ เดฐเตเดชเตเดเดฐเดฟเดเตเดเดคเต.
เดเตฝเดชเตเดชเดพเดฆเดฟเดชเตเดชเดฟเดเตเดเตเดจเตเดจ เดฎเตเดทเตเดจเดฟเตฝ เดเตปเดธเตเดฑเตเดฑเดพเตพ เดเตเดฏเตเดคเดฟเดฐเดฟเดเตเดเตเดจเตเดจ, API เดตเดดเดฟ เดฒเดญเดฟเดเตเดเตเดจเตเดจ Kinesis-เดเดเตปเดฑเต, Kinesis Data Analytics เดตเดดเดฟ เดเดตเดถเตเดฏเดฎเตเดณเตเดณ เดธเตเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเต เดกเดพเดฑเตเดฑ เดธเตเดตเดฏเดฎเตเดต เดชเดพเดดเตเดธเต เดเตเดฏเตเดฏเตเดเดฏเตเด เดเตเดฐเดพเตปเดธเตเดฎเดฟเดฑเตเดฑเต เดเตเดฏเตเดฏเตเดเดฏเตเด เดเตเดฏเตเดฏเตเด. เด เดธเตโเดเตเดฐเตเดฎเดฟเดจเตเดฑเต เด เดธเดเดธเตโเดเตเดค เดชเดคเดฟเดชเตเดชเต เดธเตเดฑเตเดฑเตเดฑเดฟเดฒเตเดเตเดเต เดจเตเดฐเดฟเดเตเดเต เดเดดเตเดคเดชเตเดชเตเดเตเด. DynamoDB-เดฏเดฟเตฝ เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเดฟเดฐเดฟเดเตเดเตเดจเตเดจ เดฑเต เดกเดพเดฑเตเดฑ เดธเตเดฑเตเดฑเตเดฑเตเดเต, AWS เดเตเดตเดฟเดเตเดเต เดธเตเดฑเตเดฑเต เดชเตเดฒเตเดณเตเดณ BI เดเตเดณเตเดเตพ เดตเดดเดฟ เดเดดเดคเตเดคเดฟเดฒเตเดณเตเดณ เดเดฟเดเตเดเดฑเตเดฑเต เดตเดฟเดถเดเดฒเดจเด เด เดจเตเดตเดฆเดฟเดเตเดเตเด.
เดฎเตเดดเตเดตเตป เด เดเดฟเดธเตเดฅเดพเดจ เดธเตเดเดฐเตเดฏเดเตเดเดณเตเด เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเตเดณเตเดณ เดฐเดฃเตเดเต เดเดชเตเดทเดจเตเดเตพ เดเดเตเดเตพ เดชเดฐเดฟเดเดฃเดฟเดเตเดเตเด:
- เดฎเดพเดจเตเดตเตฝ - AWS เดฎเดพเดจเตเดเตเดฎเตเดจเตเดฑเต เดเตบเดธเตเตพ เดตเดดเดฟ;
- เดเตเดฑเดพเดซเตเด เดเตเดกเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดเตปเดซเตเดฐเดพเดธเตเดเตเดฐเดเตเดเตผ เด เดฒเดธเดฐเดพเดฏ เดเดเตเดเตเดฎเตเดฑเตเดฑเตผเดฎเดพเตผเดเตเดเตเดณเตเดณเดคเดพเดฃเต;
เดตเดฟเดเดธเดฟเดค เดธเดเดตเดฟเดงเดพเดจเดคเตเดคเดฟเดจเตเดฑเต เดตเดพเดธเตเดคเตเดตเดฟเดฆเตเดฏ
เดเดชเดฏเตเดเดฟเดเตเด เดเดเดเดเตเดเตพ:
Aviasales API - เด API เดจเตฝเดเตเดจเตเดจ เดกเดพเดฑเตเดฑ เดคเตเดเตผเดจเตเดจเตเดณเตเดณ เดเดฒเตเดฒเดพ เดเตเดฒเดฟเดเตพเดเตเดเตเด เดเดชเดฏเตเดเดฟเดเตเดเตเด;EC2 เดชเตเดฐเตเดกเตเดฏเตเดธเตผ เดเดฆเดพเดนเดฐเดฃเด โ เดเตปเดชเตเดเตเดเต เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเด เดเดจเดฑเตเดฑเตเดฑเต เดเตเดฏเตเดฏเตเดจเตเดจ เดเตเดฒเตเดกเดฟเดฒเต เดเดฐเต เดธเดพเดงเดพเดฐเดฃ เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเตป:เดเดฟเดจเดฟเดธเดฟเดธเต เดเดเดจเตเดฑเต เดฎเตเดทเตเดจเดฟเตฝ เดชเตเดฐเดพเดฆเตเดถเดฟเดเดฎเดพเดฏเดฟ เดเตปเดธเตเดฑเตเดฑเดพเตพ เดเตเดฏเตเดคเดฟเดฐเดฟเดเตเดเตเดจเตเดจ เดเดฐเต เดเดพเดต เดเดชเตเดฒเดฟเดเตเดเตเดทเดจเดพเดฃเต, เด เดคเต เดเตเดจเดธเดฟเดธเต (เดเตเดจเดธเดฟเดธเต เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเดเดธเต เด เดฒเตเดฒเตเดเตเดเดฟเตฝ เดเดฟเดจเดฟเดธเดฟเดธเต เดซเดฏเตผเดนเตเดธเต) เดฒเตเดเตเดเต เดกเดพเดฑเตเดฑ เดถเตเดเดฐเดฟเดเตเดเดพเดจเตเด เด เดฏเดฏเตเดเตเดเดพเดจเตเด เดเดณเตเดชเตเดชเดฎเตเดณเตเดณ เดฎเดพเตผเดเด เดจเตฝเดเตเดจเตเดจเต. เดจเดฟเตผเดฆเตเดฆเดฟเดทเตโเด เดกเดฏเดฑเดเตโเดเดฑเดฟเดเดณเดฟเดฒเต เดเดฐเต เดเตเดเตเดเด เดซเดฏเดฒเตเดเตพ เดเดเดจเตเดฑเต เดจเดฟเดฐเดจเตเดคเดฐเด เดจเดฟเดฐเตเดเตเดทเดฟเดเตเดเตเดเดฏเตเด เดชเตเดคเดฟเดฏ เดกเดพเดฑเตเดฑ Kinesis-เดฒเตเดเตเดเต เด เดฏเดฏเตเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต;API เดเตเดณเตผ เดธเตโเดเตเดฐเดฟเดชเตเดฑเตเดฑเต - API-เดฏเดฟเดฒเตเดเตเดเต เด เดญเตเดฏเตผเดคเตเดฅเดจเดเตพ เดจเดเดคเตเดคเตเดเดฏเตเด เดชเตเดฐเดคเดฟเดเดฐเดฃเด Kinesis เดเดเดจเตเดฑเต เดจเดฟเดฐเตเดเตเดทเดฟเดเตเดเตเดจเตเดจ เดเดฐเต เดซเตเตพเดกเดฑเดฟเดฒเตเดเตเดเต เดเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจ เดเดฐเต เดชเตเดคเตเดคเตบ เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต;
Kinesis เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเดฎเตเดเตพ - เดตเดฟเดถเดพเดฒเดฎเดพเดฏ เดธเตเดเตเดฏเดฟเดฒเดฟเดเดเต เดเดดเดฟเดตเตเดเดณเตเดณเตเดณ เดคเดคเตเดธเดฎเดฏ เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเดฎเดฟเดเดเต เดธเตเดตเดจเด;เดเดฟเดจเดฟเดธเดฟเดธเต เด เดจเดฒเดฟเดฑเตเดฑเดฟเดเตเดธเต เดคเดคเตเดธเดฎเดฏเด เดธเตเดเตเดฐเตเดฎเดฟเดเดเต เดกเดพเดฑเตเดฑเดฏเตเดเต เดตเดฟเดถเดเดฒเดจเด เดฒเดณเดฟเดคเดฎเดพเดเตเดเตเดจเตเดจ เดเดฐเต เดธเตเตผเดตเตผเดฒเตเดธเต เดธเตเดตเดจเดฎเดพเดฃเต. เดเดฎเดธเตเตบ เดเตเดจเดธเดฟเดธเต เดกเดพเดฑเตเดฑเดพ เด เดจเดฒเดฟเดฑเตเดฑเดฟเดเตโเดธเต เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดเดฑเดตเดฟเดเดเตเดเตพ เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตเดฏเตเดเดฏเตเด เดเตปเดเดฎเดฟเดเดเต เดกเดพเดฑเตเดฑเดฏเตเดเต เดเดคเต เดตเตเดณเดฟเดฏเดตเตเด เดเตเดเดพเดฐเตเดฏเด เดเตเดฏเตเดฏเดพเตป เดธเตเดตเดฏเดฎเตเดต เดธเตเดเตเดฏเดฟเดฒเตเดเตเดฏเตเดฏเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต;AWS Lambda โ เดฌเดพเดเตเดเดชเตเดชเต เดเตเดฏเตเดฏเดพเดคเตเดฏเตเด เดธเตเตผเดตเดฑเตเดเตพ เดธเดเตเดเตเดเดฐเดฟเดเตเดเดพเดคเตเดฏเตเด เดเตเดกเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดชเตเดชเดฟเดเตเดเดพเตป เดจเดฟเดเตเดเดณเต เด เดจเตเดตเดฆเดฟเดเตเดเตเดจเตเดจ เดเดฐเต เดธเตเดตเดจเด. เดเดฐเต เดเตเดณเดฟเดจเตเด เดเดฒเตเดฒเดพ เดเดฎเตเดชเตเดฏเตเดเตเดเดฟเดเดเต เดชเดตเดฑเตเด เดธเตเดตเดฏเดฎเตเดต เดธเตเดเตเดฏเดฟเตฝ เดเตเดฏเตเดฏเดชเตเดชเตเดเตเดจเตเดจเต;เดเดฎเดธเตเตบ เดกเตเดจเดพเดฎเตเดกเดฟเดฌเดฟ - เดเดคเต เดธเตเดเตเดฏเดฟเดฒเดฟเดฒเตเด เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเดฎเตเดชเตเตพ 10 เดฎเดฟเดฒเตเดฒเดฟเดธเตเดเตเดเตปเดกเดฟเตฝ เดคเดพเดดเตเดฏเตเดณเตเดณ เดเดพเดฒเดคเดพเดฎเดธเด เดจเตฝเดเตเดจเตเดจ เดเต-เดตเดพเดฒเตเดฏเต เดเตเดกเดฟเดเดณเตเดเตเดฏเตเด เดกเตเดเตเดฏเตเดฎเตเดจเตเดฑเตเดเดณเตเดเตเดฏเตเด เดเดฐเต เดกเดพเดฑเตเดฑเดพเดฌเตเดธเต. DynamoDB เดเดชเดฏเตเดเดฟเดเตเดเตเดฎเตเดชเตเตพ, เดจเดฟเดเตเดเตพ เดเดคเตเดเตเดเดฟเดฒเตเด เดธเตเตผเดตเดฑเตเดเตพ เดชเตเดฐเตเดตเดฟเดทเตป เดเตเดฏเตเดฏเตเดเดฏเต เดชเดพเดเตเดเต เดเตเดฏเตเดฏเตเดเดฏเต เดจเดฟเดฏเดจเตเดคเตเดฐเดฟเดเตเดเตเดเดฏเต เดเตเดฏเตเดฏเตเดฃเตเดเดคเดฟเดฒเตเดฒ. เดฒเดญเตเดฏเดฎเดพเดฏ เดตเดฟเดญเดตเดเตเดเดณเตเดเต เด เดณเดตเต เดเตเดฐเดฎเตเดเดฐเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเตเด เดเดฏเตผเดจเตเดจ เดชเตเดฐเดเดเดจเด เดจเดฟเดฒเดจเดฟเตผเดคเตเดคเตเดจเตเดจเดคเดฟเดจเตเด DynamoDB เดชเดเตเดเดฟเดเดเตพ เดธเตเดตเดฏเดฎเตเดต เดธเตเดเตเดฏเดฟเตฝ เดเตเดฏเตเดฏเตเดจเตเดจเต. เดธเดฟเดธเตเดฑเตเดฑเด เด เดกเตเดฎเดฟเดจเดฟเดธเตเดเตเดฐเตเดทเตป เดเดตเดถเตเดฏเดฎเดฟเดฒเตเดฒ;เดเดฎเดธเตเตบ เดเดธเตเดเตปเดเดธเต - เดชเดฌเตเดฒเดฟเดทเตผ-เดธเดฌเตโเดธเตโเดเตเดฐเตเดฌเตผ (เดชเดฌเต/เดธเดฌเต) เดฎเตเดกเตฝ เดเดชเดฏเตเดเดฟเดเตเดเต เดธเดจเตเดฆเตเดถเดเตเดเตพ เด เดฏเดฏเตโเดเตเดเตเดจเตเดจเดคเดฟเดจเตเดณเตเดณ เดชเตเตผเดฃเตเดฃเดฎเดพเดฏเดฟ เดจเดฟเดฏเดจเตเดคเตเดฐเดฟเดค เดธเตเดตเดจเด, เด เดคเดฟเดฒเตเดเต เดจเดฟเดเตเดเตพเดเตเดเต เดฎเตเดเตเดฐเตเดธเตผเดตเตเดธเตเดเดณเตเด เดกเดฟเดธเตเดเตเดฐเดฟเดฌเตเดฏเตเดเตเดเดกเต เดธเดฟเดธเตเดฑเตเดฑเดเตเดเดณเตเด เดธเตเตผเดตเตผเดฒเตเดธเต เดเดชเตเดฒเดฟเดเตเดเตเดทเดจเตเดเดณเตเด เดตเตเตผเดคเดฟเดฐเดฟเดเตเดเดพเดจเดพเดเตเด. เดฎเตเดฌเตเตฝ เดชเตเดทเต เด เดฑเดฟเดฏเดฟเดชเตเดชเตเดเตพ, SMS เดธเดจเตเดฆเตเดถเดเตเดเตพ, เดเดฎเตเดฏเดฟเดฒเตเดเตพ เดเดจเตเดจเดฟเดตเดฏเดฟเดฒเตเดเต เด เดจเตเดคเดฟเดฎ เดเดชเดฏเตเดเตเดคเดพเดเตเดเตพเดเตเดเต เดตเดฟเดตเดฐเดเตเดเตพ เด เดฏเดฏเตเดเตเดเดพเตป SNS เดเดชเดฏเตเดเดฟเดเตเดเดพเด.
เดชเตเดฐเดพเดฐเดเดญ เดชเดฐเดฟเดถเตเดฒเดจเด
เดกเดพเดฑเตเดฑเดพ เดซเตเดฒเต เด
เดจเตเดเดฐเดฟเดเตเดเดพเตป, Aviasales API เดจเตฝเดเตเดจเตเดจ เดเดฏเตผเดฒเตเตป เดเดฟเดเตเดเดฑเตเดฑเต เดตเดฟเดตเดฐเดเตเดเตพ เดเดชเดฏเตเดเดฟเดเตเดเดพเตป เดเดพเตป เดคเตเดฐเตเดฎเดพเดจเดฟเดเตเดเต. IN
เด เดคเดฟเดจเดพเตฝ, เดจเดฎเตเดเตเดเต เดฐเดเดฟเดธเตเดฑเตเดฑเตผ เดเตเดฏเตเดคเต เดเตเดเตเดเตบ เดจเตเดเดพเด.
เดเดฐเต เดเดฆเดพเดนเดฐเดฃ เด เดญเตเดฏเตผเดคเตเดฅเดจ เดเตเดตเดเต:
http://api.travelpayouts.com/v2/prices/month-matrix?currency=rub&origin=LED&destination=HKT&show_to_affiliates=true&token=TOKEN_API
เด เดญเตเดฏเตผเดคเตเดฅเดจเดฏเดฟเตฝ เดเดฐเต เดเตเดเตเดเตบ เดตเตเดฏเดเตเดคเดฎเดพเดเตเดเดฟเดเตเดเตเดฃเตเดเต API-เตฝ เดจเดฟเดจเตเดจเต เดกเดพเดฑเตเดฑ เดธเตเดตเตเดเดฐเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเตเดณเตเดณ เดฎเตเดเดณเดฟเดฒเตเดณเตเดณ เดฐเตเดคเดฟ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเด, เดชเดเตเดทเต เดเดพเตป เดนเตเดกเดฑเดฟเดฒเตเดเต เดเดเตเดธเดธเต เดเตเดเตเดเตบ เดเตเดฎเดพเดฑเดพเตป เดเดเตเดฐเดนเดฟเดเตเดเตเดจเตเดจเต, เด เดคเดฟเดจเดพเตฝ เดเดเตเดเตพ เด เดฐเตเดคเดฟ api_caller.py เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเดฟเตฝ เดเดชเดฏเตเดเดฟเดเตเดเตเด.
เดเดคเตเดคเดฐเด เดเดฆเดพเดนเดฐเดฃเด:
{{
"success":true,
"data":[{
"show_to_affiliates":true,
"trip_class":0,
"origin":"LED",
"destination":"HKT",
"depart_date":"2015-10-01",
"return_date":"",
"number_of_changes":1,
"value":29127,
"found_at":"2015-09-24T00:06:12+04:00",
"distance":8015,
"actual":true
}]
}
เดฎเตเดเดณเดฟเดฒเตเดณเตเดณ เดเดฆเดพเดนเดฐเดฃ API เดชเตเดฐเดคเดฟเดเดฐเดฃเด เดธเตเดจเตเดฑเต เดชเตเดฑเตเดฑเตเดดเตโเดธเตเดฌเตผเดเดฟเตฝ เดจเดฟเดจเตเดจเต เดซเตเดเตเดเดฟเดฒเตเดเตเดเตเดณเตเดณ เดเดฐเต เดเดฟเดเตเดเดฑเตเดฑเต เดเดพเดฃเดฟเดเตเดเตเดจเตเดจเต... เด, เดเดจเตเดคเตเดฐเต เดธเตเดตเดชเตเดจเด...
เดเดพเตป เดเดธเดพเดจเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดเดณเดพเดฏเดคเดฟเดจเดพเตฝ, เดซเตเดเตเดเดฑเตเดฑเต เดเดชเตเดชเตเตพ "เดเดฐเต เดธเตเดตเดชเตเดจเด เดฎเดพเดคเตเดฐเดฎเดพเดฃเต", เดจเดฎเตเดเตเดเต เดธเตเดจเตเดฑเต เดชเตเดฑเตเดฑเตเดดเตโเดธเตเดฌเตผเดเดฟเตฝ เดจเดฟเดจเตเดจเต เดเดธเดพเดจเดฟเดฒเตเดเตเดเตเดณเตเดณ เดเดฟเดเตเดเดฑเตเดฑเตเดเตพเดเตเดเดพเดฏเดฟ เดจเตเดเตเดเดพเด.
เดจเดฟเดเตเดเตพเดเตเดเต เดเดคเดฟเดจเดเด เดเดฐเต AWS เด เดเตเดเตเดฃเตเดเต เดเดฃเตเดเตเดจเตเดจเต เดเดคเต เด เดจเตเดฎเดพเดจเดฟเดเตเดเตเดจเตเดจเต. Kinesis, SMS เดตเดดเดฟเดฏเตเดณเตเดณ เด เดฑเดฟเดฏเดฟเดชเตเดชเตเดเตพ เด เดฏเดฏเตเดเตเดเตฝ เดเดจเตเดจเดฟเดต เดตเดพเตผเดทเดฟเดเดคเตเดคเดฟเตฝ เดเตพเดชเตเดชเตเดเตเดคเตเดคเดฟเดฏเดฟเดเตเดเดฟเดฒเตเดฒ เดเดจเตเดจ เดตเดธเตเดคเตเดคเดฏเดฟเดฒเตเดเตเดเต เดชเตเดฐเดคเตเดฏเตเด เดถเตเดฐเดฆเตเดง เดเดเตผเดทเดฟเดเตเดเดพเตป เดเดพเตป เดเดเตเดฐเดนเดฟเดเตเดเตเดจเตเดจเต.
เดซเตเดฐเต เดเดฏเตผ (เดธเตเดเดจเตเดฏ เดเดชเดฏเตเดเด) . เดเดคเตเดเตเดเตเดฏเดพเดฃเตเดเตเดเดฟเดฒเตเด, เดเตเดฑเดเตเดเต เดกเตเดณเตผ เดฎเดจเดธเตเดธเดฟเตฝ เดตเตเดเตเดเตเดเตเดฃเตเดเต, เดจเดฟเตผเดฆเตเดฆเดฟเดทเตเด เดธเดฟเดธเตเดฑเตเดฑเด เดจเดฟเตผเดฎเตเดฎเดฟเดเตเดเดพเดจเตเด เด เดคเต เดเดณเดฟเดเตเดเดพเดจเตเด เดคเดฟเดเดเตเดเตเด เดธเดพเดฆเตเดงเตเดฏเดฎเดพเดฃเต. เดเตเดเดพเดคเต, เดคเตเตผเดเตเดเดฏเดพเดฏเตเด, เด เดต เดเดตเดถเตเดฏเดฎเดฟเดฒเตเดฒเดพเดคเตเดคเดคเดฟเดจเต เดถเตเดทเด เดเดฒเตเดฒเดพ เดเดฑเดตเดฟเดเดเตเดเดณเตเด เดเดฒเตเดฒเดพเดคเดพเดเตเดเดพเตป เดฎเดฑเดเตเดเดฐเตเดคเต.
เดญเดพเดเตเดฏเดตเดถเดพเตฝ, เดเดเตเดเดณเตเดเต เดชเตเดฐเดคเดฟเดฎเดพเดธ เดธเตเดเดจเตเดฏ เดชเดฐเดฟเดงเดฟเดเตพ เดชเดพเดฒเดฟเดเตเดเตเดเดฏเดพเดฃเตเดเตเดเดฟเตฝ DynamoDb, lambda เดซเดเดเตโเดทเดจเตเดเตพ เดธเตเดเดจเตเดฏเดฎเดพเดฏเดฟเดฐเดฟเดเตเดเตเด. เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต, DynamoDB-เดฏเตโเดเตเดเต: 25 GB เดธเดเดญเดฐเดฃเด, 25 WCU/RCU, 100 เดฆเดถเดฒเดเตเดทเด เด เดจเตเดตเตเดทเดฃเดเตเดเตพ. เดเตเดเดพเดคเต เดชเตเดฐเดคเดฟเดฎเดพเดธเด เดเดฐเต เดฆเดถเดฒเดเตเดทเด เดฒเดพเดเดก เดซเดเดเตโเดทเตป เดเตเดณเตเดเดณเตเด.
เดฎเดพเดจเตเดตเตฝ เดธเดฟเดธเตเดฑเตเดฑเด เดตเดฟเดจเตเดฏเดพเดธเด
Kinesis เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเดฎเตเดเตพ เดธเดเตเดเตเดเดฐเดฟเดเตเดเตเดจเตเดจเต
เดจเดฎเตเดเตเดเต Kinesis เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเด เดธเตเดตเดจเดคเตเดคเดฟเดฒเตเดเตเดเต เดชเตเดฏเดฟ เดฐเดฃเตเดเต เดชเตเดคเดฟเดฏ เดธเตเดเตเดฐเตเดฎเตเดเตพ เดธเตเดทเตเดเดฟเดเตเดเดพเด, เดเดฐเตเดจเตเดจเดฟเดจเตเด เดเดฐเต เดทเดพเตผเดกเต.
เดเดฐเต เดทเดพเตผเดกเต เดเดจเตเดคเดพเดฃเต?
เดเดฎเดธเตเตบ เดเตเดจเดธเดฟเดธเต เดธเตเดเตเดฐเตเดฎเดฟเดจเตเดฑเต เด
เดเดฟเดธเตเดฅเดพเดจ เดกเดพเดฑเตเดฑเดพ เดเตเดฐเดพเตปเดธเตเดซเตผ เดฏเตเดฃเดฟเดฑเตเดฑเดพเดฃเต เดทเดพเตผเดกเต. เดเดฐเต เดธเตเดเตโเดฎเตเดจเตเดฑเต เดเตปเดชเตเดเตเดเต เดกเดพเดฑเตเดฑ เดเตเดฎเดพเดฑเตเดฑเด 1 MB/s เดตเตเดเดคเดฏเดฟเดฒเตเด เดเดเตเดเตโเดชเตเดเตเดเต เดกเดพเดฑเตเดฑเดพ เดเตเดฎเดพเดฑเตเดฑเด 2 MB/s เดตเตเดเดคเดฏเดฟเดฒเตเด เดจเตฝเดเตเดจเตเดจเต. เดเดฐเต เดธเตเดเตโเดฎเตเดจเตเดฑเต เดธเตเดเตเดเตปเดกเดฟเตฝ 1000 PUT เดเตปเดเตเดฐเดฟเดเตพ เดตเดฐเต เดชเดฟเดจเตเดคเตเดฃเดฏเตเดเตเดเตเดจเตเดจเต. เดเดฐเต เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเด เดธเตเดทเตเดเดฟเดเตเดเตเดฎเตเดชเตเตพ, เดเดตเดถเตเดฏเดฎเดพเดฏ เดธเตเดเตเดฎเตเดจเตเดฑเตเดเดณเตเดเต เดเดฃเตเดฃเด เดจเดฟเดเตเดเตพ เดตเตเดฏเดเตเดคเดฎเดพเดเตเดเตเดฃเตเดเดคเตเดฃเตเดเต. เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต, เดจเดฟเดเตเดเตพเดเตเดเต เดฐเดฃเตเดเต เดธเตเดเตเดฎเตเดจเตเดฑเตเดเดณเตเดณเตเดณ เดเดฐเต เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเด เดธเตเดทเตเดเดฟเดเตเดเดพเตป เดเดดเดฟเดฏเตเด. เด เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเด 2 MB/s-เตฝ เดเตปเดชเตเดเตเดเต เดกเดพเดฑเตเดฑ เดเตเดฎเดพเดฑเตเดฑเดตเตเด 4 MB/s-เตฝ เดเดเตเดเตเดชเตเดเตเดเต เดกเดพเดฑเตเดฑ เดเตเดฎเดพเดฑเตเดฑเดตเตเด เดจเตฝเดเตเด, เดเดคเต เดธเตเดเตเดเตปเดกเดฟเตฝ 2000 PUT เดฑเตเดเตเดเตเตผเดกเตเดเตพ เดตเดฐเต เดชเดฟเดจเตเดคเตเดฃเดฏเตเดเตเดเตเดจเตเดจเต.
เดจเดฟเดเตเดเดณเตเดเต เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดเตเดเตเดคเตฝ เดเดทเดฃเดเตเดเตพ, เด เดคเดฟเดจเตเดฑเต เดคเตเดฐเตเดชเตเดเตเดเต เดตเตผเดฆเตเดงเดฟเดเตเดเตเด. เดคเดคเตเดตเดคเตเดคเดฟเตฝ, เดซเตเดฒเตเดเตพ เดธเตเดเตเดฏเดฟเตฝ เดเตเดฏเตเดฏเตเดจเตเดจเดคเต เดเดเตเดเดจเตเดฏเดพเดฃเต - เดเดทเดฃเดเตเดเตพ เดเตเตผเดคเตเดคเต. เดเดจเตเดจเดพเตฝ เดจเดฟเดเตเดเดณเตเดเต เดชเดเตเดเตฝ เดเตเดเตเดคเตฝ เดเดทเดฃเดเตเดเตพ, เดเดฏเตผเดจเตเดจ เดตเดฟเดฒ. เดเดฐเต เดทเดพเตผเดกเดฟเดจเตเด เดฎเดฃเดฟเดเตเดเตเดฑเดฟเดจเต 1,5 เดธเตเดจเตเดฑเตเด เดเดฐเต เดฎเดฟเดฒเตเดฏเตบ PUT เดชเตเดฒเตเดกเต เดฏเตเดฃเดฟเดฑเตเดฑเตเดเตพเดเตเดเต 1.4 เดธเตเดจเตเดฑเตเด เด เดงเดฟเดเดฎเดพเดฏเดฟ เดเดฟเดฒเดตเดพเดเตเด.
เดชเตเดฐเดฟเดจเตเดชเตเดชเด เดเดฐเต เดชเตเดคเดฟเดฏ เดธเตเดเตเดฐเตเด เดธเตเดทเตเดเดฟเดเตเดเดพเด เดเดฏเตผเดฒเตเตป_เดเดฟเดเตเดเดฑเตเดฑเตเดเตพ, เดเดฐเต เดเดทเตเดฃเด เด เดตเดจเต เดฎเดคเดฟเดฏเดพเดเตเด:
เดเดจเดฟ เดชเตเดฐเดฟเดจเตเดชเตเดชเด เดฎเดฑเตเดฑเตเดฐเต เดคเตเดฐเตเดกเต เดเดฃเตเดเดพเดเตเดเดพเด เดชเตเดฐเดคเตเดฏเตเด_เดธเตเดเตเดฐเตเด:
เดชเตเดฐเตเดกเตเดฏเตเดธเตผ เดธเตเดฑเตเดฑเดชเตเดชเต
เดเดฐเต เดเดพเดธเตโเดเต เดตเดฟเดถเดเดฒเดจเด เดเตเดฏเตเดฏเดพเตป, เดเดฐเต เดกเดพเดฑเตเดฑ เดชเตเดฐเตเดกเตเดฏเตเดธเตผ เดเดจเตเดจ เดจเดฟเดฒเดฏเดฟเตฝ เดเดฐเต เดธเดพเดงเดพเดฐเดฃ EC2 เดเดฆเดพเดนเดฐเดฃเด เดเดชเดฏเตเดเดฟเดเตเดเดพเตฝ เดฎเดคเดฟ. เดเดคเต เดถเดเตเดคเดตเตเด เดเตเดฒเดตเตเดฑเดฟเดฏเดคเตเดฎเดพเดฏ เดเดฐเต เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเตป เดเดฏเดฟเดฐเดฟเดเตเดเดฃเดฎเตเดจเตเดจเดฟเดฒเตเดฒ; เดเดฐเต เดธเตเดชเตเดเตเดเต t2.เดฎเตเดเตเดฐเต เดจเดจเตเดจเดพเดฏเดฟ เดเตเดฏเตเดฏเตเด.
เดชเตเดฐเดงเดพเดจ เดเตเดฑเดฟเดชเตเดชเต: เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต, เดจเดฟเดเตเดเตพ เดเดฟเดคเตเดฐเด เดเดชเดฏเตเดเดฟเดเตเดเดฃเด - Amazon Linux AMI 2018.03.0, Kinesis เดเดเดจเตเดฑเต เดตเตเดเดคเตเดคเดฟเตฝ เดธเดฎเดพเดฐเดเดญเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต เดเดคเดฟเดจเต เดเตเดฑเดเตเดเต เดเตเดฐเดฎเตเดเดฐเดฃเดเตเดเดณเตเดฃเตเดเต.
EC2 เดธเตเดตเดจเดคเตเดคเดฟเดฒเตเดเตเดเต เดชเตเดเตเด, เดเดฐเต เดชเตเดคเดฟเดฏ เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเตป เดธเตเดทเตโเดเดฟเดเตเดเตเด, เดซเตเดฐเต เดเดฏเดฑเดฟเตฝ เดเตพเดชเตเดชเตเดเตเดคเตเดคเดฟเดฏเดฟเดฐเดฟเดเตเดเตเดจเตเดจ เดเตเดชเตเดชเต t2.micro เดเดชเดฏเตเดเดฟเดเตเดเต เดเดตเดถเตเดฏเดฎเตเดณเตเดณ เดเดเดเด เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด:
เดชเตเดคเตเดคเดพเดฏเดฟ เดธเตเดทเตเดเดฟเดเตเด เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเดจเต เดเตเดจเดธเดฟเดธเต เดธเตเดตเดจเดตเตเดฎเดพเดฏเดฟ เดธเดเดตเดฆเดฟเดเตเดเดพเตป เดเดดเดฟเดฏเดฃเดฎเตเดเตเดเดฟเตฝ, เด
เดคเดฟเดจเตเดณเตเดณ เด
เดตเดเดพเดถเดเตเดเตพ เดจเตฝเดเดฃเด. เดเดฐเต IAM เดฑเตเตพ เดจเดฟเดฏเตเดเดฟเดเตเดเตเด เดเดจเตเดจเดคเดพเดฃเต เดเดคเดฟเดจเตเดณเตเดณ เดเดฑเตเดฑเดตเตเด เดจเดฒเตเดฒ เดฎเดพเตผเดเด. เด
เดคเดฟเดจเดพเตฝ, เดธเตเดฑเตเดฑเตเดชเตเดชเต 3: เดเตเตบเดซเดฟเดเตผ เดเตปเดธเตเดฑเตเดฑเตปเดธเต เดกเตเดฑเตเดฑเตเดฏเดฟเตฝเดธเต เดธเตเดเตเดฐเตเดจเดฟเตฝ, เดจเดฟเดเตเดเตพ เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเดฃเด เดชเตเดคเดฟเดฏ IAM เดฑเตเตพ เดธเตเดทเตเดเดฟเดเตเดเตเด:
EC2 เดจเดพเดฏเดฟ เดเดฐเต IAM เดฑเตเตพ เดธเตเดทเตเดเดฟเดเตเดเตเดจเตเดจเต
เดคเตเดฑเดเตเดเตเดจเตเดจ เดตเดฟเตปเดกเตเดฏเดฟเตฝ, เดเดเตเดเตพ EC2 เดจเดพเดฏเดฟ เดเดฐเต เดชเตเดคเดฟเดฏ เดฑเตเตพ เดธเตเดทเตเดเดฟเดเตเดเตเดเดฏเดพเดฃเตเดจเตเดจเต เดคเดฟเดฐเดเตเดเตเดเตเดคเตเดคเต เด
เดจเตเดฎเดคเดฟ เดตเดฟเดญเดพเดเดคเตเดคเดฟเดฒเตเดเตเดเต เดชเตเดเตเด:
เดชเดฐเดฟเดถเตเดฒเดจ เดเดฆเดพเดนเดฐเดฃเด เดเดชเดฏเตเดเดฟเดเตเดเต, เดฑเดฟเดธเตเดดเตโเดธเต เด
เดตเดเดพเดถเดเตเดเดณเตเดเต เดเตเดฐเดพเดจเตเดฒเดพเตผ เดเตเตบเดซเดฟเดเดฑเตเดทเดจเตเดฑเต เดเดฒเตเดฒเดพ เดธเดเตเดเตเตผเดฃเดคเดเดณเดฟเดฒเตเดเตเดเตเด เดเดเตเดเตพ เดชเตเดเตเดฃเตเดเดคเดฟเดฒเตเดฒ, เด
เดคเดฟเดจเดพเตฝ AmazonKinesisFullAccess, CloudWatchFullAccess เดเดจเตเดจเดฟเดต เดฎเตเตปเดเตเดเตเดเดฟ เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตโเดค เดจเดฏเดเตเดเตพ เดเดเตเดเตพ เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด.
เด เดฑเตเดณเดฟเดจเต เดเดฟเดฒ เด เตผเดคเตเดฅเดตเดคเตเดคเดพเดฏ เดชเตเดฐเต เดจเตฝเดเดพเด, เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต: EC2-KinesisStreams-FullAccess. เดซเดฒเด เดเตเดตเดเตเดฏเตเดณเตเดณ เดเดฟเดคเตเดฐเดคเตเดคเดฟเตฝ เดเดพเดฃเดฟเดเตเดเดฟเดฐเดฟเดเตเดเตเดจเตเดจเดคเตเดชเตเดฒเต เดเดฏเดฟเดฐเดฟเดเตเดเดฃเด:
เด เดชเตเดคเดฟเดฏ เดฑเตเตพ เดธเตเดทเตเดเดฟเดเตเดเดคเดฟเดจเต เดถเตเดทเด, เดธเตเดทเตเดเดฟเดเตเด เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเตป เดเตปเดธเตโเดฑเตเดฑเตปเดธเดฟเดฒเตเดเตเดเต เดเดคเต เด
เดฑเตเดฑเดพเดเตเดเตเดเตเดฏเตเดฏเดพเตป เดฎเดฑเดเตเดเดฐเตเดคเต:
เดเดเตเดเตพ เด เดธเตเดเตเดฐเตเดจเดฟเตฝ เดฎเดฑเตเดฑเตเดจเตเดจเตเด เดฎเดพเดฑเตเดฑเดฟเดฒเตเดฒ, เด
เดเตเดคเตเดค เดตเดฟเตปเดกเตเดเดณเดฟเดฒเตเดเตเดเต เดจเตเดเตเดเตเด.
เดนเดพเตผเดกเต เดกเตเดฐเตเดตเต เดเตเดฐเดฎเตเดเดฐเดฃเดเตเดเดณเตเด เดเดพเดเตเดเดณเตเด เดกเดฟเดซเตเตพเดเตเดเดพเดฏเดฟ เด เดตเดถเตเดทเดฟเดชเตเดชเดฟเดเตเดเดพเด (เดเดพเดเตเดเตพ เดเดชเดฏเตเดเดฟเดเตเดเตเดจเตเดจเดคเต เดจเดฒเตเดฒ เดฐเตเดคเดฟเดฏเดพเดฃเตเดเตเดเดฟเดฒเตเด, เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต เดเดฐเต เดชเตเดฐเตเดเตเดเดฟเดฒเตเด เดจเตฝเดเตเดเดฏเตเด เดชเดฐเดฟเดธเตเดฅเดฟเดคเดฟเดฏเต เดธเตเดเดฟเดชเตเดชเดฟเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเด).
เดเดชเตเดชเตเตพ เดเดเตเดเตพ เดธเตเดฑเตเดฑเตเดชเตเดชเต 6-เดฒเดพเดฃเต: เดธเตเดเตเดฏเตเดฐเดฟเดฑเตเดฑเดฟ เดเตเดฐเตเดชเตเดชเต เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตเดฏเตเด, เด เดตเดฟเดเต เดจเดฟเดเตเดเตพเดเตเดเต เดชเตเดคเดฟเดฏเตเดฐเตเดฃเตเดฃเด เดธเตเดทเตเดเดฟเดเตเดเตเดเดฏเต เดจเดฟเดฒเดตเดฟเดฒเตเดณเตเดณ เดธเตเดเตเดฏเตเดฐเดฟเดฑเตเดฑเดฟ เดเตเดฐเตเดชเตเดชเต เดตเตเดฏเดเตเดคเดฎเดพเดเตเดเตเดเดฏเต เดเตเดฏเตเดฏเตเดฃเตเดเดคเตเดฃเตเดเต, เดเดคเต ssh (เดชเตเตผเดเตเดเต 22) เดตเดดเดฟ เด เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดฒเตเดเตเดเต เดเดฃเดเตเดฑเตเดฑเตเดเตเดฏเตเดฏเดพเตป เดจเดฟเดเตเดเดณเต เด เดจเตเดตเดฆเดฟเดเตเดเตเดจเตเดจเต. เด เดตเดฟเดเต เดเดฑเดตเดฟเดเด -> เดเดจเตเดฑเต เดเดชเดฟ เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด, เดจเดฟเดเตเดเตพเดเตเดเต เดเดฆเดพเดนเดฐเดฃเด เดธเดฎเดพเดฐเดเดญเดฟเดเตเดเดพเด.
เดเดคเต เดฑเดฃเตเดฃเดฟเดเดเต เดธเตเดฑเตเดฑเดพเดฑเตเดฑเดธเดฟเดฒเตเดเตเดเต เดฎเดพเดฑเตเดฎเตเดชเตเตพ, เดจเดฟเดเตเดเตพเดเตเดเต ssh เดตเดดเดฟ เดเดคเดฟเดฒเตเดเตเดเต เดเดฃเดเตเดฑเตเดฑเตเดเตเดฏเตเดฏเดพเตป เดถเตเดฐเดฎเดฟเดเตเดเดพเด.
เดเตเดจเดธเดฟเดธเต เดเดเดจเตเดฑเตเดฎเดพเดฏเดฟ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเดพเตป, เดฎเตเดทเตเดจเดฟเดฒเตเดเตเดเต เดตเดฟเดเดฏเดเดฐเดฎเดพเดฏเดฟ เดเดฃเดเตเดฑเตเดฑเตเดเตเดฏเตโเดคเดคเดฟเดจเต เดถเตเดทเด, เดจเดฟเดเตเดเตพ เดเตเตผเดฎเดฟเดจเดฒเดฟเตฝ เดเดจเดฟเดชเตเดชเดฑเดฏเตเดจเตเดจ เดเดฎเดพเตปเดกเตเดเตพ เดจเตฝเดเดฃเด:
sudo yum -y update
sudo yum install -y python36 python36-pip
sudo /usr/bin/pip-3.6 install --upgrade pip
sudo yum install -y aws-kinesis-agent
API เดชเตเดฐเดคเดฟเดเดฐเดฃเดเตเดเตพ เดธเดเดฐเดเตเดทเดฟเดเตเดเดพเตป เดจเดฎเตเดเตเดเต เดเดฐเต เดซเตเตพเดกเตผ เดธเตเดทเตเดเดฟเดเตเดเดพเด:
sudo mkdir /var/log/airline_tickets
เดเดเดจเตเดฑเต เดเดฐเดเดญเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต เดฎเตเดฎเตเดชเต, เดจเดฟเดเตเดเตพ เด เดคเดฟเดจเตเดฑเต เดเตเตบเดซเดฟเดเตผ เดเตเดฐเดฎเตเดเดฐเดฟเดเตเดเตเดฃเตเดเดคเตเดฃเตเดเต:
sudo vim /etc/aws-kinesis/agent.json
agent.json เดซเดฏเดฒเดฟเดจเตเดฑเต เดเดณเตเดณเดเดเตเดเด เดเดคเตเดชเตเดฒเตเดฏเดพเดฏเดฟเดฐเดฟเดเตเดเดฃเด:
{
"cloudwatch.emitMetrics": true,
"kinesis.endpoint": "",
"firehose.endpoint": "",
"flows": [
{
"filePattern": "/var/log/airline_tickets/*log",
"kinesisStream": "airline_tickets",
"partitionKeyOption": "RANDOM",
"dataProcessingOptions": [
{
"optionName": "CSVTOJSON",
"customFieldNames": ["cost","trip_class","show_to_affiliates",
"return_date","origin","number_of_changes","gate","found_at",
"duration","distance","destination","depart_date","actual","record_id"]
}
]
}
]
}
เดเตเตบเดซเดฟเดเดฑเตเดทเตป เดซเดฏเดฒเดฟเตฝ เดจเดฟเดจเตเดจเต เดเดพเดฃเดพเดจเดพเดเตเดจเตเดจเดคเตเดชเตเดฒเต, /var/log/airline_tickets/ เดกเดฏเดฑเดเตโเดเดฑเดฟเดฏเดฟเดฒเต .log เดเดเตโเดธเตโเดฑเตเดฑเตปเดทเตป เดเดชเดฏเตเดเดฟเดเตเดเต เดเดเดจเตเดฑเต เดซเดฏเดฒเตเดเตพ เดจเดฟเดฐเตเดเตเดทเดฟเดเตเดเตเดเดฏเตเด เด เดตเดฏเต เดชเดพเดดเตโเดธเต เดเตเดฏเตเดฏเตเดเดฏเตเด airline_tickets เดธเตโเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเต เดฎเดพเดฑเตเดฑเตเดเดฏเตเด เดเตเดฏเตเดฏเตเด.
เดเดเตเดเตพ เดธเตเดตเดจเด เดชเตเดจเดฐเดพเดฐเดเดญเดฟเดเตเดเตเดเดฏเตเด เด เดคเต เดชเตเดฐเดตเตผเดคเตเดคเดจเดเตเดทเดฎเดฎเดพเดฃเตเดจเตเดจเต เดเดฑเดชเตเดชเดพเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต:
sudo service aws-kinesis-agent restart
เดเดชเตเดชเตเตพ API-เดฏเดฟเตฝ เดจเดฟเดจเตเดจเต เดกเดพเดฑเตเดฑ เด เดญเตเดฏเตผเดคเตเดฅเดฟเดเตเดเตเดจเตเดจ เดชเตเดคเตเดคเตบ เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต เดกเตเตบเดฒเตเดกเต เดเตเดฏเตเดฏเดพเด:
REPO_PATH=https://raw.githubusercontent.com/igorgorbenko/aviasales_kinesis/master/producer
wget $REPO_PATH/api_caller.py -P /home/ec2-user/
wget $REPO_PATH/requirements.txt -P /home/ec2-user/
sudo chmod a+x /home/ec2-user/api_caller.py
sudo /usr/local/bin/pip3 install -r /home/ec2-user/requirements.txt
Api_caller.py เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต Aviasales-เตฝ เดจเดฟเดจเตเดจเต เดกเดพเดฑเตเดฑ เด เดญเตเดฏเตผเดคเตเดฅเดฟเดเตเดเตเดเดฏเตเด เดฒเดญเดฟเดเตเด เดชเตเดฐเดคเดฟเดเดฐเดฃเด Kinesis เดเดเดจเตเดฑเต เดธเตเดเดพเตป เดเตเดฏเตเดฏเตเดจเตเดจ เดกเดฏเดฑเดเตเดเดฑเดฟเดฏเดฟเตฝ เดธเดเดฐเดเตเดทเดฟเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต. เด เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต เดจเดเดชเตเดชเดฟเดฒเดพเดเตเดเตเดจเตเดจเดคเต เดคเดฟเดเดเตเดเตเด เดธเตเดฑเตเดฑเดพเตปเดกเตเตผเดกเต เดเดฃเต, เดเดฐเต TicketsApi เดเตเดฒเดพเดธเต เดเดฃเตเดเต, API เด เดธเดฎเดจเตเดตเดฟเดคเดฎเดพเดฏเดฟ เดตเดฒเดฟเดเตเดเดพเตป เดเดคเต เดจเดฟเดเตเดเดณเต เด เดจเตเดตเดฆเดฟเดเตเดเตเดจเตเดจเต. เด เดเตเดฒเดพเดธเดฟเดฒเตเดเตเดเต เดเดเตเดเตพ เดเดฐเต เดเตเดเตเดเตบ เดเดณเตเดณ เดเดฐเต เดคเดฒเดเตเดเตเดเตเดเต เดเตเดฎเดพเดฑเตเดเดฏเตเด เดชเดพเดฐเดพเดฎเตเดฑเตเดฑเดฑเตเดเตพ เด เดญเตเดฏเตผเดคเตเดฅเดฟเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต:
class TicketsApi:
"""Api caller class."""
def __init__(self, headers):
"""Init method."""
self.base_url = BASE_URL
self.headers = headers
async def get_data(self, data):
"""Get the data from API query."""
response_json = {}
async with ClientSession(headers=self.headers) as session:
try:
response = await session.get(self.base_url, data=data)
response.raise_for_status()
LOGGER.info('Response status %s: %s',
self.base_url, response.status)
response_json = await response.json()
except HTTPError as http_err:
LOGGER.error('Oops! HTTP error occurred: %s', str(http_err))
except Exception as err:
LOGGER.error('Oops! An error ocurred: %s', str(err))
return response_json
def prepare_request(api_token):
"""Return the headers and query fot the API request."""
headers = {'X-Access-Token': api_token,
'Accept-Encoding': 'gzip'}
data = FormData()
data.add_field('currency', CURRENCY)
data.add_field('origin', ORIGIN)
data.add_field('destination', DESTINATION)
data.add_field('show_to_affiliates', SHOW_TO_AFFILIATES)
data.add_field('trip_duration', TRIP_DURATION)
return headers, data
async def main():
"""Get run the code."""
if len(sys.argv) != 2:
print('Usage: api_caller.py <your_api_token>')
sys.exit(1)
return
api_token = sys.argv[1]
headers, data = prepare_request(api_token)
api = TicketsApi(headers)
response = await api.get_data(data)
if response.get('success', None):
LOGGER.info('API has returned %s items', len(response['data']))
try:
count_rows = log_maker(response)
LOGGER.info('%s rows have been saved into %s',
count_rows,
TARGET_FILE)
except Exception as e:
LOGGER.error('Oops! Request result was not saved to file. %s',
str(e))
else:
LOGGER.error('Oops! API request was unsuccessful %s!', response)
เดเดเดจเตเดฑเดฟเดจเตเดฑเต เดถเดฐเดฟเดฏเดพเดฏ เดเตเดฐเดฎเตเดเดฐเดฃเดเตเดเดณเตเด เดชเตเดฐเดตเตผเดคเตเดคเดจเดเตเดทเดฎเดคเดฏเตเด เดชเดฐเดฟเดถเตเดงเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต, api_caller.py เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดชเตเดชเดฟเดเตเดเตเดจเตเดจเดคเต เดชเดฐเตเดเตเดทเดฟเดเตเดเดพเด:
sudo ./api_caller.py TOKEN
เดเดเตเดเตพ เดเดเดจเตเดฑเต เดฒเตเดเตเดเดณเดฟเดฒเตเด เดเดฏเตผเดฒเตเตป_เดเดฟเดเตเดเดฑเตเดฑเต เดกเดพเดฑเตเดฑเดพ เดธเตเดเตเดฐเตเดฎเดฟเดฒเต เดฎเตเดฃเดฟเดฑเตเดฑเดฑเดฟเดเดเต เดเดพเดฌเดฟเดฒเตเด เดเตเดฒเดฟเดฏเตเดเต เดซเดฒเด เดจเตเดเตเดเตเดจเตเดจเต:
tail -f /var/log/aws-kinesis-agent/aws-kinesis-agent.log
เดจเดฟเดเตเดเตพเดเตเดเต เดเดพเดฃเดพเดจเดพเดเตเดจเตเดจเดคเตเดชเตเดฒเต, เดเดฒเตเดฒเดพเด เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเดจเตเดจเต, Kinesis เดเดเดจเตเดฑเต เดตเดฟเดเดฏเดเดฐเดฎเดพเดฏเดฟ เดธเตเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเต เดกเดพเดฑเตเดฑ เด
เดฏเดฏเตเดเตเดเตเดจเตเดจเต. เดเดจเดฟ เดจเดฎเตเดเตเดเต เดเตบเดธเตเดฏเตเดฎเตผ เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตเดฏเดพเด.
Kinesis เดกเดพเดฑเตเดฑ เด เดจเดฒเดฟเดฑเตเดฑเดฟเดเตเดธเต เดธเดเตเดเตเดเดฐเดฟเดเตเดเตเดจเตเดจเต
เดจเดฎเตเดเตเดเต เดฎเตเดดเตเดตเตป เดธเดฟเดธเตเดฑเตเดฑเดคเตเดคเดฟเดจเตเดฑเตเดฏเตเด เดเตเดจเตเดฆเตเดฐ เดเดเดเดคเตเดคเดฟเดฒเตเดเตเดเต เดชเตเดเดพเด - Kinesis Data Analytics-เตฝ kinesis_analytics_airlines_app เดเดจเตเดจ เดชเตเดฐเดฟเตฝ เดเดฐเต เดชเตเดคเดฟเดฏ เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดธเตเดทเตเดเดฟเดเตเดเตเด:
SQL เดญเดพเดท เดเดชเดฏเตเดเดฟเดเตเดเต Kinesis เดธเตเดเตเดฐเตเดฎเตเดเดณเดฟเตฝ เดจเดฟเดจเตเดจเต เดคเดคเตเดธเดฎเดฏ เดกเดพเดฑเตเดฑ เด
เดจเดฒเดฟเดฑเตเดฑเดฟเดเตเดธเต เดจเดเดคเตเดคเดพเตป Kinesis เดกเดพเดฑเตเดฑ เด
เดจเดฒเดฟเดฑเตเดฑเดฟเดเตเดธเต เดจเดฟเดเตเดเดณเต เด
เดจเตเดตเดฆเดฟเดเตเดเตเดจเตเดจเต. เดเดคเต เดชเตเตผเดฃเตเดฃเดฎเดพเดฏเตเด เดเดเตเดเตเดธเตโเดเตเดฒเดฟเดเดเต เดธเตเดตเดจเดฎเดพเดฃเต (เดเดฟเดจเตเดธเดฟเดธเต เดธเตเดเตเดฐเตเดฎเตเดเดณเดฟเตฝ เดจเดฟเดจเตเดจเต เดตเตเดฏเดคเตเดฏเดธเตเดคเดฎเดพเดฏเดฟ):
- เดเดฑเดตเดฟเด เดกเดพเดฑเตเดฑเดฏเดฟเดฒเตเดเตเดเตเดณเตเดณ เด เดญเตเดฏเตผเดคเตเดฅเดจเดเดณเต เด เดเดฟเดธเตเดฅเดพเดจเดฎเดพเดเตเดเดฟ เดชเตเดคเดฟเดฏ เดธเตเดเตเดฐเตเดฎเตเดเตพ (เดเดเตเดเตเดชเตเดเตเดเต เดธเตเดเตเดฐเตเด) เดธเตเดทเตเดเดฟเดเตเดเดพเตป เดจเดฟเดเตเดเดณเต เด เดจเตเดตเดฆเดฟเดเตเดเตเดจเตเดจเต;
- เดเดชเตเดฒเดฟเดเตเดเตเดทเดจเตเดเตพ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเดฎเตเดชเตเตพ เดธเดเดญเดตเดฟเดเตเด เดชเดฟเดถเดเตเดเดณเตเดณเตเดณ เดเดฐเต เดธเตเดเตเดฐเตเด เดจเตฝเดเตเดจเตเดจเต (เดชเดฟเดถเดเต เดธเตเดเตเดฐเตเด);
- เดเตปเดชเตเดเตเดเต เดกเดพเดฑเตเดฑ เดธเตเดเตเด เดธเตเดตเดฏเดฎเตเดต เดจเดฟเตผเดฃเตเดฃเดฏเดฟเดเตเดเดพเตป เดเดดเดฟเดฏเตเด (เดเดตเดถเตเดฏเดฎเตเดเตเดเดฟเตฝ เด เดคเต เดธเตเดตเดฎเตเดงเดฏเดพ เดชเตเดจเตผ เดจเดฟเตผเดตเดเดฟเดเตเดเดพเดตเตเดจเตเดจเดคเดพเดฃเต).
เดเดคเตเดฐเต เดตเดฟเดฒเดเตเดฑเดเตเด เดธเตเดตเดจเดฎเดฒเตเดฒ - เดเดฐเต เดฎเดฃเดฟเดเตเดเตเดฑเดฟเดจเต 0.11 USD, เด เดคเดฟเดจเดพเตฝ เดจเดฟเดเตเดเตพ เดเดคเต เดถเตเดฐเดฆเตเดงเดพเดชเตเตผเดตเตเดตเด เดเดชเดฏเตเดเดฟเดเตเดเตเดเดฏเตเด เดชเตเตผเดคเตเดคเดฟเดฏเดพเดเตเดเตเดฎเตเดชเตเตพ เด เดคเต เดเดฒเตเดฒเดพเดคเดพเดเตเดเตเดเดฏเตเด เดตเตเดฃเด.
เดจเดฎเตเดเตเดเต เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดกเดพเดฑเตเดฑ เดเดฑเดตเดฟเดเดคเตเดคเดฟเดฒเตเดเตเดเต เดฌเดจเตเดงเดฟเดชเตเดชเดฟเดเตเดเดพเด:
เดเดเตเดเตพ เดฌเดจเตเดงเดฟเดชเตเดชเดฟเดเตเดเดพเตป เดชเตเดเตเดจเตเดจ เดธเตเดเตเดฐเตเด เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด (airline_tickets):
เด
เดเตเดคเตเดคเดคเดพเดฏเดฟ, เดจเดฟเดเตเดเตพ เดเดฐเต เดชเตเดคเดฟเดฏ IAM เดฑเตเตพ เด
เดฑเตเดฑเดพเดเตเดเตเดเตเดฏเตเดฏเตเดฃเตเดเดคเตเดฃเตเดเต, เด
เดคเตเดตเดดเดฟ เด
เดชเตเดฒเดฟเดเตเดเตเดทเดจเต เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดจเดฟเดจเตเดจเต เดตเดพเดฏเดฟเดเตเดเดพเดจเตเด เดธเตเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเต เดเดดเตเดคเดพเดจเตเด เดเดดเดฟเดฏเตเด. เดเดคเต เดเตเดฏเตเดฏเตเดจเตเดจเดคเดฟเดจเต, เดเดเตโเดธเดธเต เดชเตเตผเดฎเดฟเดทเตปเดธเต เดฌเตเดฒเตเดเตเดเดฟเตฝ เดเดจเตเดจเตเด เดฎเดพเดฑเตเดฑเดพเดคเดฟเดฐเตเดจเตเดจเดพเตฝ เดฎเดคเดฟ:
เดเดชเตเดชเตเตพ เดธเตเดเตเดฐเตเดฎเดฟเดฒเต เดกเดพเดฑเตเดฑเดพ เดธเตเดเตเดฎ เดเดฃเตเดเตเดคเตเดคเตเดจเตเดจเดคเดฟเดจเต เด
เดญเตเดฏเตผเดคเตเดฅเดฟเดเตเดเดพเด; เดเดคเต เดเตเดฏเตเดฏเตเดจเตเดจเดคเดฟเดจเต, "เดธเตเดเตเดฎ เดเดฃเตเดเตเดคเตเดคเตเด" เดฌเดเตเดเดฃเดฟเตฝ เดเตเดฒเดฟเดเตเดเตเดเตเดฏเตเดฏเตเด. เดคเตฝเดซเดฒเดฎเดพเดฏเดฟ, IAM เดฑเตเตพ เด
เดชเตโเดกเตเดฑเตเดฑเต เดเตเดฏเตเดฏเดชเตเดชเตเดเตเด (เดชเตเดคเดฟเดฏ เดเดฐเตเดฃเตเดฃเด เดธเตเดทเตโเดเดฟเดเตเดเตเด) เดเตเดเดพเดคเต เดธเตโเดเตเดฐเตเดฎเดฟเตฝ เดเดคเดฟเดจเดเด เดเดคเตเดคเดฟเดฏ เดกเดพเดฑเตเดฑเดฏเดฟเตฝ เดจเดฟเดจเตเดจเต เดธเตเดเตเดฎ เดเดฃเตเดเตเดคเตเดคเตฝ เดธเดฎเดพเดฐเดเดญเดฟเดเตเดเตเด:
เดเดชเตเดชเตเตพ เดจเดฟเดเตเดเตพ SQL เดเดกเดฟเดฑเตเดฑเดฑเดฟเดฒเตเดเตเดเต เดชเตเดเตเดฃเตเดเดคเตเดฃเตเดเต. เดจเดฟเดเตเดเตพ เด เดฌเดเตเดเดฃเดฟเตฝ เดเตเดฒเดฟเดเตเดเตเดเตเดฏเตเดฏเตเดฎเตเดชเตเตพ, เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดธเดฎเดพเดฐเดเดญเดฟเดเตเดเดพเตป เดเดตเดถเตเดฏเดชเตเดชเตเดเตเดจเตเดจ เดเดฐเต เดตเดฟเตปเดกเต เดฆเตเดถเตเดฏเดฎเดพเดเตเด - เดจเดฟเดเตเดเตพ เดฒเตเดเตเดเต เดเตเดฏเตเดฏเตเดฃเตเดเดคเต เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด:
เดเดจเดฟเดชเตเดชเดฑเดฏเตเดจเตเดจ เดฒเดณเดฟเดคเดฎเดพเดฏ เดเตเดฆเตเดฏเด SQL เดเดกเดฟเดฑเตเดฑเตผ เดตเดฟเตปเดกเตเดฏเดฟเดฒเตเดเตเดเต เดคเดฟเดฐเตเดเตเด, เดคเตเดเตผเดจเตเดจเต SQL เดธเดเดฐเดเตเดทเดฟเดเตเดเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดชเตเดชเดฟเดเตเดเตเด เดเตเดฒเดฟเดเตเดเตเดเตเดฏเตเดฏเตเด:
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ("cost" DOUBLE, "gate" VARCHAR(16));
CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM "cost", "gate"
FROM "SOURCE_SQL_STREAM_001"
WHERE "cost" < 5000
and "gate" = 'Aeroflot';
เดฑเดฟเดฒเตเดทเดฃเตฝ เดกเดพเดฑเตเดฑเดพเดฌเตเดธเตเดเดณเดฟเตฝ, เดฑเตเดเตเดเตเตผเดกเตเดเตพ เดเตเตผเดเตเดเดพเตป เดเตปเดธเตเตผเดเตเดเต เดธเตเดฑเตเดฑเตเดฑเตเดฑเตโเดฎเตเดจเตเดฑเตเดเดณเตเด เดกเดพเดฑเตเดฑ เด เดจเตเดตเตเดทเดฟเดเตเดเดพเตป เดเดฐเต SELECT เดธเตเดฑเตเดฑเตเดฑเตเดฑเตโเดฎเตเดจเตเดฑเตเด เดเดชเดฏเตเดเดฟเดเตเดเต เดจเดฟเดเตเดเตพ เดชเดเตเดเดฟเดเดเดณเตเดฎเดพเดฏเดฟ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเดจเตเดจเต. Amazon Kinesis Data Analytics-เตฝ, เดจเดฟเดเตเดเตพ เดธเตเดเตเดฐเตเดฎเตเดเตพ (เดธเตเดเตเดฐเตเดฎเตเดเตพ), เดชเดฎเตเดชเตเดเตพ (PUMP-เดเตพ) เดเดจเตเดจเดฟเดตเดฏเดฟเตฝ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเดจเตเดจเต - เดเดฐเต เดเดชเตเดฒเดฟเดเตเดเตเดทเดจเดฟเดฒเต เดเดฐเต เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดกเดพเดฑเตเดฑ เดฎเดฑเตเดฑเตเดฐเต เดธเตเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเต เดเตเตผเดเตเดเตเดจเตเดจ เดคเตเดเตผเดเตเดเดฏเดพเดฏ เดคเดฟเดฐเตเดเตฝ เด เดญเตเดฏเตผเดคเตเดฅเดจเดเตพ.
เดฎเตเดเดณเดฟเตฝ เด เดตเดคเดฐเดฟเดชเตเดชเดฟเดเตเด SQL เดเตเดฆเตเดฏเด เด เดฏเตเดฏเดพเดฏเดฟเดฐเด เดฑเตเดฌเดฟเดณเดฟเตฝ เดคเดพเดดเตเดฏเตเดณเตเดณ เดเดฏเดฑเตเดซเตเดฒเตเดเตเดเต เดเดฟเดเตเดเดฑเตเดฑเตเดเตพเดเตเดเดพเดฏเตเดณเตเดณ เดคเดฟเดฐเดฏเดฒเตเดเตพ. เด เดตเตเดฏเดตเดธเตเดฅเดเตพ เดชเดพเดฒเดฟเดเตเดเตเดจเตเดจ เดเดฒเตเดฒเดพ เดฑเตเดเตเดเตเตผเดกเตเดเดณเตเด DESTINATION_SQL_STREAM เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดธเตเดฅเดพเดชเดฟเดเตเดเตเด.
เดกเตเดธเตเดฑเตเดฑเดฟเดจเตเดทเตป เดฌเตเดฒเตเดเตเดเดฟเตฝ, เดธเตโเดชเตเดทเตเดฏเตฝ_เดธเตเดเตเดฐเตเด เดธเตเดเตเดฐเตเด เดคเดฟเดฐเดเตเดเตเดเตเดเตเดเตเด, เดเตเดเดพเดคเต เดเตป-เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดธเตเดเตเดฐเตเด เดจเดพเดฎเดคเตเดคเดฟเตฝ DESTINATION_SQL_STREAM เดกเตเดฐเตเดชเตเดชเต-เดกเตเตบ เดฒเดฟเดธเตเดฑเตเดฑเดฟเตฝ:
เดเดฒเตเดฒเดพ เดเตเดคเตเดฐเดฟเดฎเดคเตเดตเดเตเดเดณเตเดเตเดฏเตเด เดซเดฒเด เดเตเดตเดเตเดฏเตเดณเตเดณ เดเดฟเดคเตเดฐเดคเตเดคเดฟเดจเต เดธเดฎเดพเดจเดฎเดพเดฏ เดเดจเตเดจเดพเดฏเดฟเดฐเดฟเดเตเดเดฃเด:
เดเดฐเต SNS เดตเดฟเดทเดฏเด เดธเตเดทเตโเดเดฟเดเตเดเตเดเดฏเตเด เดธเดฌเตโเดธเตโเดเตเดฐเตเดฌเต เดเตเดฏเตเดฏเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต
เดฒเดณเดฟเดคเดฎเดพเดฏ เด เดฑเดฟเดฏเดฟเดชเตเดชเต เดธเตเดตเดจเดคเตเดคเดฟเดฒเตเดเตเดเต เดชเตเดฏเดฟ เด เดตเดฟเดเต เดเดฏเตผเดฒเตเตปเดธเต เดเดจเตเดจ เดชเตเดฐเดฟเตฝ เดเดฐเต เดชเตเดคเดฟเดฏ เดตเดฟเดทเดฏเด เดธเตเดทเตเดเดฟเดเตเดเตเด:
เด เดตเดฟเดทเดฏเด เดธเดฌเตโเดธเตโเดเตเดฐเตเดฌเตเดเตเดฏเตโเดคเต SMS เด
เดฑเดฟเดฏเดฟเดชเตเดชเตเดเตพ เด
เดฏเดฏเตโเดเตเดเตเดจเตเดจ เดฎเตเดฌเตเตฝ เดซเตเตบ เดจเดฎเตเดชเตผ เดธเตเดเดฟเดชเตเดชเดฟเดเตเดเตเด:
DynamoDB-เดฏเดฟเตฝ เดเดฐเต เดชเดเตเดเดฟเด เดธเตเดทเตเดเดฟเดเตเดเตเด
เด เดตเดฐเตเดเต airline_tickets เดธเตโเดเตเดฐเตเดฎเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เด เดธเดเดธเตโเดเตเดค เดกเดพเดฑเตเดฑ เดธเดเดญเดฐเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต, DynamoDB-เดฏเดฟเตฝ เด เดคเต เดชเตเดฐเดฟเตฝ เดเดฐเต เดชเดเตเดเดฟเด เดธเตเดทเตโเดเดฟเดเตเดเดพเด. เดเดเตเดเตพ เดฑเตเดเตเดเตเตผเดกเต_เดเดกเดฟ เดชเตเดฐเดพเดฅเดฎเดฟเด เดเต เดเดฏเดฟ เดเดชเดฏเตเดเดฟเดเตเดเตเด:
เดเดฐเต เดฒเดพเดเดก เดซเดเดเตเดทเตป เดเดณเดเตเดเตผ เดธเตเดทเตเดเดฟเดเตเดเตเดจเตเดจเต
เดจเดฎเตเดเตเดเต เดเดณเดเตเดเตผ เดเดจเตเดจ เดชเตเดฐเดฟเตฝ เดเดฐเต เดฒเดพเดเดก เดซเดเดเตโเดทเตป เดธเตเดทเตโเดเดฟเดเตเดเดพเด, เดเดฏเตผเดฒเตเตป_เดเดฟเดเตเดเดฑเตเดฑเต เดธเตเดเตเดฐเตเด เดตเตเดเตเดเตเดเตเดชเตเดชเต เดจเดเดคเตเดคเตเดเดฏเตเด เด เดตเดฟเดเต เดชเตเดคเดฟเดฏ เดฑเตเดเตเดเตเตผเดกเตเดเตพ เดเดฃเตเดเตเดคเตเดคเตเดเดฏเดพเดฃเตเดเตเดเดฟเตฝ, เด เดฑเตเดเตเดเตเตผเดกเตเดเตพ DynamoDB เดเตเดฌเดฟเดณเดฟเตฝ เดเตเตผเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเด เดเดจเตเดจเดคเดพเดฃเต เดเดคเดฟเดจเตเดฑเต เดเตเดฎเดคเดฒ. เดตเตเดฏเดเตเดคเดฎเดพเดฏเตเด, เดกเดฟเดซเตเตพเดเตเดเต เด เดตเดเดพเดถเดเตเดเตพเดเตเดเต เดชเตเดฑเดฎเต, เด เดฒเดพเดเดกเดฏเตเดเตเดเต Kinesis เดกเดพเดฑเตเดฑ เดธเตโเดเตเดฐเตเดฎเดฟเดฒเตเดเตเดเตเดณเตเดณ เดฑเตเดกเต เดเดเตโเดธเดธเตเด เดกเตเดจเดพเดฎเตเดกเดฟเดฌเดฟเดฏเดฟเดฒเตเดเตเดเตเดณเตเดณ เดฑเตเดฑเตเดฑเต เดเดเตโเดธเดธเตเดธเตเด เดเดฃเตเดเดพเดฏเดฟเดฐเดฟเดเตเดเดฃเด.
เดเดณเดเตเดเตผ เดฒเดพเดเดก เดซเดเดเตโเดทเดจเตเดตเตเดฃเตเดเดฟ เดเดฐเต IAM เดฑเตเตพ เดธเตเดทเตโเดเดฟเดเตเดเตเดจเตเดจเต
เดเดฆเตเดฏเด, Lambda-TicketsProcessingRole เดเดจเตเดจ เดชเตเดฐเดฟเตฝ เดฒเดพเดเดกเดฏเตโเดเตเดเดพเดฏเดฟ เดเดฐเต เดชเตเดคเดฟเดฏ IAM เดฑเตเตพ เดธเตเดทเตโเดเดฟเดเตเดเดพเด:
เดชเดฐเตเดเตเดทเดฃ เดเดฆเดพเดนเดฐเดฃเดคเตเดคเดฟเดจเต, เดเตเดตเดเตเดฏเตเดณเตเดณ เดเดฟเดคเตเดฐเดคเตเดคเดฟเตฝ เดเดพเดฃเดฟเดเตเดเดฟเดฐเดฟเดเตเดเตเดจเตเดจเดคเตเดชเตเดฒเต, เดฎเตเตปเดเตเดเตเดเดฟ เดเตเดฐเดฎเตเดเดฐเดฟเดเตเด AmazonKinesisReadOnlyAccess, AmazonDynamoDBFullAccess เดจเดฏเดเตเดเตพ เดคเดฟเดเดเตเดเตเด เด
เดจเตเดฏเตเดเตเดฏเดฎเดพเดฃเต:
เดเดฏเตผเดฒเตเตป_เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดชเตเดคเดฟเดฏ เดเตปเดเตเดฐเดฟเดเตพ เดชเตเดฐเดตเตเดถเดฟเดเตเดเตเดฎเตเดชเตเตพ Kinesis-เตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดเดฐเต เดเตเดฐเดฟเดเตผ เดเดชเดฏเตเดเดฟเดเตเดเดพเดฃเต เด เดฒเดพเดเดก เดฒเตเดเตเดเต เดเตเดฏเตเดฏเตเดฃเตเดเดคเต, เด
เดคเดฟเดจเดพเตฝ เดเดเตเดเตพ เดเดฐเต เดชเตเดคเดฟเดฏ เดเตเดฐเดฟเดเตผ เดเตเตผเดเตเดเตเดฃเตเดเดคเตเดฃเตเดเต:
เดเตเดกเต เดคเดฟเดฐเตเดเตเดเดฏเตเด เดฒเดพเดเดก เดธเดเดฐเดเตเดทเดฟเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเด เดฎเดพเดคเตเดฐเดฎเดพเดฃเต เด
เดตเดถเตเดทเดฟเดเตเดเตเดจเตเดจเดคเต.
"""Parsing the stream and inserting into the DynamoDB table."""
import base64
import json
import boto3
from decimal import Decimal
DYNAMO_DB = boto3.resource('dynamodb')
TABLE_NAME = 'airline_tickets'
class TicketsParser:
"""Parsing info from the Stream."""
def __init__(self, table_name, records):
"""Init method."""
self.table = DYNAMO_DB.Table(table_name)
self.json_data = TicketsParser.get_json_data(records)
@staticmethod
def get_json_data(records):
"""Return deserialized data from the stream."""
decoded_record_data = ([base64.b64decode(record['kinesis']['data'])
for record in records])
json_data = ([json.loads(decoded_record)
for decoded_record in decoded_record_data])
return json_data
@staticmethod
def get_item_from_json(json_item):
"""Pre-process the json data."""
new_item = {
'record_id': json_item.get('record_id'),
'cost': Decimal(json_item.get('cost')),
'trip_class': json_item.get('trip_class'),
'show_to_affiliates': json_item.get('show_to_affiliates'),
'origin': json_item.get('origin'),
'number_of_changes': int(json_item.get('number_of_changes')),
'gate': json_item.get('gate'),
'found_at': json_item.get('found_at'),
'duration': int(json_item.get('duration')),
'distance': int(json_item.get('distance')),
'destination': json_item.get('destination'),
'depart_date': json_item.get('depart_date'),
'actual': json_item.get('actual')
}
return new_item
def run(self):
"""Batch insert into the table."""
with self.table.batch_writer() as batch_writer:
for item in self.json_data:
dynamodb_item = TicketsParser.get_item_from_json(item)
batch_writer.put_item(dynamodb_item)
print('Has been added ', len(self.json_data), 'items')
def lambda_handler(event, context):
"""Parse the stream and insert into the DynamoDB table."""
print('Got event:', event)
parser = TicketsParser(TABLE_NAME, event['Records'])
parser.run()
เดเดฐเต เดฒเดพเดเดก เดซเดเดเตโเดทเตป เดจเตเดเตเดเดฟเดซเดฏเตผ เดธเตเดทเตโเดเดฟเดเตเดเตเดจเตเดจเต
เดฐเดฃเตเดเดพเดฎเดคเตเดคเต เดธเตเดเตเดฐเตเด (เดธเตเดชเตเดทเตเดฏเตฝ_เดธเตเดเตเดฐเตเด) เดจเดฟเดฐเตเดเตเดทเดฟเดเตเดเตเดเดฏเตเด เดเดธเตเดเตปเดเดธเดฟเดฒเตเดเตเดเต เดเดฐเต เด เดฑเดฟเดฏเดฟเดชเตเดชเต เด เดฏเดฏเตเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจ เดฐเดฃเตเดเดพเดฎเดคเตเดคเต เดฒเดพเดเดก เดซเดเดเตเดทเตป เดธเดฎเดพเดจเดฎเดพเดฏ เดฐเตเดคเดฟเดฏเดฟเตฝ เดธเตเดทเตเดเดฟเดเตเดเดฟเดฐเดฟเดเตเดเตเดจเตเดจเต. เด เดคเดฟเดจเดพเตฝ, เด เดฒเดพเดเดกเดฏเตเดเตเดเต Kinesis-เตฝ เดจเดฟเดจเตเดจเต เดตเดพเดฏเดฟเดเตเดเดพเดจเตเด เดคเดจเตเดจเดฟเดฐเดฟเดเตเดเตเดจเตเดจ เดเดฐเต SNS เดตเดฟเดทเดฏเดคเตเดคเดฟเดฒเตเดเตเดเต เดธเดจเตเดฆเตเดถเดเตเดเตพ เด เดฏเดฏเตโเดเตเดเดพเดจเตเด เดเดเตโเดธเดธเต เดเดฃเตเดเดพเดฏเดฟเดฐเดฟเดเตเดเดฃเด, เด เดคเต เด เดตเดฟเดทเดฏเดคเตเดคเดฟเดจเตเดฑเต เดเดฒเตเดฒเดพ เดตเดฐเดฟเดเตเดเดพเตผเดเตเดเตเด (เดเดฎเตเดฏเดฟเตฝ, SMS, เดฎเตเดคเดฒเดพเดฏเดต) SNS เดธเตเดตเดจเด เด เดฏเดฏเตโเดเตเดเตเด.
เดเดฐเต IAM เดฑเตเตพ เดธเตเดทเตเดเดฟเดเตเดเตเดจเตเดจเต
เดเดฆเตเดฏเด, เด เดฒเดพเดเดกเดฏเตโเดเตเดเดพเดฏเดฟ เดเดเตเดเตพ IAM เดฑเตเตพ Lambda-KinesisAlarm เดธเตเดทเตโเดเดฟเดเตเดเตเดจเตเดจเต, เดคเตเดเตผเดจเตเดจเต เดธเตเดทเตโเดเดฟเดเตเดเตเดจเตเดจ alarm_notifier lambda-เดฏเตโเดเตเดเต เด เดฑเตเตพ เดจเดฟเดฏเตเดเดฟเดเตเดเตเดจเตเดจเต:
เดธเตโเดชเตเดทเตเดฏเตฝ_เดธเตเดเตเดฐเตเดฎเดฟเตฝ เดชเตเดฐเดตเตเดถเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต เดชเตเดคเดฟเดฏ เดฑเตเดเตเดเตเตผเดกเตเดเตพเดเตเดเดพเดฏเดฟ เด เดฒเดพเดเดก เดเดฐเต เดเตเดฐเดฟเดเดฑเดฟเตฝ เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเดฃเด, เด
เดคเดฟเดจเดพเตฝ เดเดณเดเตเดเตผ เดฒเดพเดเดกเดฏเตโเดเตเดเดพเดฏเดฟ เดเดเตเดเตพ เดเตเดฏเตโเดคเดคเตเดชเตเดฒเต เดจเดฟเดเตเดเตพ เดเตเดฐเดฟเดเตผ เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตเดฏเตเดฃเตเดเดคเตเดฃเตเดเต.
เด เดฒเดพเดเดก เดเตเตบเดซเดฟเดเตผ เดเตเดฏเตเดฏเตเดจเตเดจเดคเต เดเดณเตเดชเตเดชเดฎเดพเดเตเดเตเดจเตเดจเดคเดฟเดจเต, เดจเดฎเตเดเตเดเต เดเดฐเต เดชเตเดคเดฟเดฏ เดเตปเดตเดฏเตเตบเดฎเตเดจเตเดฑเต เดตเตเดฐเดฟเดฏเดฌเดฟเตพ เด เดตเดคเดฐเดฟเดชเตเดชเดฟเดเตเดเดพเด - TOPIC_ARN, เด เดตเดฟเดเต เดเดเตเดเตพ เดเดฏเตผเดฒเตเตปเดธเต เดตเดฟเดทเดฏเดคเตเดคเดฟเดจเตเดฑเต ANR (เดเดฎเดธเตเตบ เดฑเดฟเดธเตเดดเตเดธเต เดจเดพเดฎเดเตเดเตพ) เดธเตเดฅเดพเดชเดฟเดเตเดเตเดจเตเดจเต:
เดฒเดพเดเดก เดเตเดกเต เดเตเตผเดเตเดเตเด, เดเดคเต เดเดเตเดเตเด เดธเดเตเดเตเตผเดฃเตเดฃเดฎเดฒเตเดฒ:
import boto3
import base64
import os
SNS_CLIENT = boto3.client('sns')
TOPIC_ARN = os.environ['TOPIC_ARN']
def lambda_handler(event, context):
try:
SNS_CLIENT.publish(TopicArn=TOPIC_ARN,
Message='Hi! I have found an interesting stuff!',
Subject='Airline tickets alarm')
print('Alarm message has been successfully delivered')
except Exception as err:
print('Delivery failure', str(err))
เดเดตเดฟเดเตเดฏเดพเดฃเต เดฎเดพเดจเตเดตเตฝ เดธเดฟเดธเตเดฑเตเดฑเด เดเตเตบเดซเดฟเดเดฑเตเดทเตป เดชเตเตผเดคเตเดคเดฟเดฏเดพเดเตเดเดฟเดฏเดคเตเดจเตเดจเต เดคเตเดจเตเดจเตเดจเตเดจเต. เดเดเตเดเตพ เดเดฒเตเดฒเดพเด เดถเดฐเดฟเดฏเดพเดฏเดฟ เดเตเดฐเดฎเตเดเดฐเดฟเดเตเดเดฟเดเตเดเตเดฃเตเดเตเดจเตเดจเต เดชเดฐเดฟเดถเตเดงเดฟเดเตเดเต เดเดฑเดชเตเดชเดพเดเตเดเตเด เดฎเดพเดคเตเดฐเดฎเดพเดฃเต เด เดตเดถเตเดทเดฟเดเตเดเตเดจเตเดจเดคเต.
เดเตเดฑเดพเดซเตเด เดเตเดกเดฟเตฝ เดจเดฟเดจเตเดจเต เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเตเด
เดเดตเดถเตเดฏเดฎเดพเดฏ เดคเดฏเตเดฏเดพเดฑเตเดเตเดชเตเดชเต
เดจเดฟเดเตเดเตพเดเตเดเต เดตเดฟเดคเดฐเดฃเด เดกเตเตบเดฒเตเดกเต เดเตเดฏเตเดฏเดพเด
เดเดเตเดเดจเต เดเดฐเดเดญเดฟเดเตเดเดพเด
เดชเดฆเตเดงเดคเดฟเดฏเตเดเต เดชเตเตผเดฃเตเดฃ เดเตเดกเต
เดเตเดฒเตเดกเดฟเตฝ เดจเดฟเดฒเดตเดฟเตฝ เดเตเดฑเดพเดซเตเด เดเดจเตเดคเดพเดฃเต เดธเตเดทเตโเดเดฟเดเตเดเตเดจเตเดจเดคเตเดจเตเดจเต เดเดพเดฃเตเดจเตเดจเดคเดฟเดจเต เดฎเตเดดเตเดตเตป เดเตปเดซเตเดฐเดพเดธเตเดเตเดฐเดเตเดเดฑเตเด เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเต เดฎเตเดฎเตเดชเต เดชเตเดฒเดพเตป เดเดฎเดพเตปเดกเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดชเตเดชเดฟเดเตเดเตเด เดเดจเตเดจเดคเดพเดฃเต เดเดฐเต เดจเดฒเตเดฒ เดธเดฎเตเดชเตเดฐเดฆเดพเดฏเด:
terraform.exe plan
เด เดฑเดฟเดฏเดฟเดชเตเดชเตเดเตพ เด เดฏเดฏเตเดเตเดเดพเตป เดเดฐเต เดซเตเตบ เดจเดฎเตเดชเตผ เดจเตฝเดเดพเตป เดจเดฟเดเตเดเดณเตเดเต เดเดตเดถเตเดฏเดชเตเดชเตเดเตเด. เด เดเดเตเดเดคเตเดคเดฟเตฝ เด เดคเต เดจเตฝเดเตเดฃเตเดเดคเดฟเดฒเตเดฒ.
เดชเตเดฐเตเดเตเดฐเดพเดฎเดฟเดจเตเดฑเต เดเดชเตเดชเดฑเตเดทเตป เดชเตเดฒเดพเตป เดตเดฟเดถเดเดฒเดจเด เดเตเดฏเตเดค เดถเตเดทเด, เดจเดฎเตเดเตเดเต เดเดฑเดตเดฟเดเดเตเดเตพ เดธเตเดทเตเดเดฟเดเตเดเดพเตป เดคเตเดเดเตเดเดพเด:
terraform.exe apply
เด เดเดฎเดพเตปเดกเต เด เดฏเดเตเดเดคเดฟเดจเต เดถเตเดทเด, เดเดฐเต เดซเตเตบ เดจเดฎเตเดชเตผ เดจเตฝเดเดพเตป เดจเดฟเดเตเดเดณเตเดเต เดตเตเดฃเตเดเตเด เดเดตเดถเตเดฏเดชเตเดชเตเดเตเด; เดฏเดฅเดพเตผเดคเตเดฅเดคเตเดคเดฟเตฝ เดชเตเดฐเดตเตผเดคเตเดคเดจเดเตเดเตพ เดจเดเดคเตเดคเตเดจเตเดจเดคเดฟเดจเตเดเตเดเตเดฑเดฟเดเตเดเตเดณเตเดณ เดเดฐเต เดเตเดฆเตเดฏเด เดชเตเดฐเดฆเตผเดถเดฟเดชเตเดชเดฟเดเตเดเตเดฎเตเดชเตเตพ "เด เดคเต" เดเดจเตเดจเต เดกเดฏเตฝ เดเตเดฏเตเดฏเตเด. เดฎเตเดดเตเดตเตป เดเตปเดซเตเดฐเดพเดธเตเดเตเดฐเดเตเดเดฑเตเด เดธเดเตเดเตเดเดฐเดฟเดเตเดเดพเดจเตเด EC2 เดจเตเดฑเต เดเดตเดถเตเดฏเดฎเดพเดฏ เดเดฒเตเดฒเดพ เดเตเตบเดซเดฟเดเดฑเตเดทเดจเตเดเดณเตเด เดจเดเดชเตเดชเดฟเดฒเดพเดเตเดเดพเดจเตเด เดฒเดพเดเดก เดซเดเดเตเดทเดจเตเดเตพ เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเดพเดจเตเด เดเดคเต เดจเดฟเดเตเดเดณเต เด เดจเตเดตเดฆเดฟเดเตเดเตเด.
เดเตเดฑเดพเดซเตเด เดเตเดกเดฟเดฒเตเดเต เดเดฒเตเดฒเดพ เดเดฑเดตเดฟเดเดเตเดเดณเตเด เดตเดฟเดเดฏเดเดฐเดฎเดพเดฏเดฟ เดธเตเดทเตเดเดฟเดเตเดเดคเดฟเดจเต เดถเตเดทเด, เดจเดฟเดเตเดเตพ Kinesis Analytics เดเดชเตเดฒเดฟเดเตเดเตเดทเดจเตเดฑเต เดตเดฟเดถเดฆเดพเดเดถเดเตเดเดณเดฟเดฒเตเดเตเดเต เดชเตเดเตเดฃเตเดเดคเตเดฃเตเดเต (เดจเดฟเตผเดญเดพเดเตเดฏเดตเดถเดพเตฝ, เดเตเดกเดฟเตฝ เดจเดฟเดจเตเดจเต เดเดคเต เดเดเตเดเดจเต เดจเตเดฐเดฟเดเตเดเต เดเตเดฏเตเดฏเดฃเดฎเตเดจเตเดจเต เดเดพเตป เดเดฃเตเดเตเดคเตเดคเดฟเดฏเดฟเดฒเตเดฒ).
เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดธเดฎเดพเดฐเดเดญเดฟเดเตเดเตเด:
เดเดคเดฟเดจเตเดถเตเดทเด, เดกเตเดฐเตเดชเตเดชเต-เดกเตเตบ เดฒเดฟเดธเตเดฑเตเดฑเดฟเตฝ เดจเดฟเดจเตเดจเต เดคเดฟเดฐเดเตเดเตเดเตเดคเตเดคเต เดจเดฟเดเตเดเตพ เดเตป-เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดธเตเดเตเดฐเตเด เดจเดพเดฎเด เดตเตเดฏเดเตเดคเดฎเดพเดฏเดฟ เดธเดเตเดเตเดเดฐเดฟเดเตเดเดฃเด:
เดเดชเตเดชเตเตพ เดเดฒเตเดฒเดพเด เดชเตเดเดพเตป เดคเดฏเตเดฏเดพเดฑเดพเดฃเต.
เดเดชเตเดฒเดฟเดเตเดเตเดทเตป เดชเดฐเดฟเดถเตเดงเดฟเดเตเดเตเดจเตเดจเต
เดจเดฟเดเตเดเตพ เดเดเตเดเดจเตเดฏเดพเดฃเต เดธเดฟเดธเตเดฑเตเดฑเด เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเดคเตเดจเตเดจเดคเต เดชเดฐเดฟเดเดฃเดฟเดเตเดเดพเดคเต เดคเดจเตเดจเต, เดธเตเดตเดฎเตเดงเดฏเดพ เด เดฒเตเดฒเตเดเตเดเดฟเตฝ เดเตเดฑเดพเดซเตเด เดเตเดกเต เดฎเตเดเตเดจ, เด เดคเต เดเดฐเตเดชเตเดฒเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดเตเดเตเด.
Kinesis Agent เดเตปเดธเตเดฑเตเดฑเดพเตพ เดเตเดฏเตเดคเดฟเดฐเดฟเดเตเดเตเดจเตเดจ EC2 เดตเตเตผเดเตเดตเตฝ เดฎเตเดทเตเดจเดฟเดฒเตเดเตเดเต SSH เดตเดดเดฟ เดฒเตเดเดฟเตป เดเตเดฏเตเดฏเตเดเดฏเตเด api_caller.py เดธเตเดเตเดฐเดฟเดชเตเดฑเตเดฑเต เดชเตเดฐเดตเตผเดคเตเดคเดฟเดชเตเดชเดฟเดเตเดเตเดเดฏเตเด เดเตเดฏเตเดฏเตเดจเตเดจเต.
sudo ./api_caller.py TOKEN
เดจเดฟเดเตเดเตพ เดเตเดฏเตเดฏเตเดฃเตเดเดคเต เดจเดฟเดเตเดเดณเตเดเต เดจเดฎเตเดชเดฑเดฟเดฒเตเดเตเดเต เดเดฐเต SMS เดฒเดญเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเดพเดฏเดฟ เดเดพเดคเตเดคเดฟเดฐเดฟเดเตเดเตเด:
SMS - เดเดเดฆเตเดถเด 1 เดฎเดฟเดจเดฟเดฑเตเดฑเดฟเดจเตเดณเตเดณเดฟเตฝ เดจเดฟเดเตเดเดณเตเดเต เดซเตเดฃเดฟเตฝ เดเดฐเต เดธเดจเตเดฆเตเดถเด เดเดคเตเดคเตเดจเตเดจเต:
เดคเตเดเตผเดจเตเดจเตเดณเตเดณ เดเตเดเตเดคเตฝ เดตเดฟเดถเดฆเดฎเดพเดฏ เดตเดฟเดถเดเดฒเดจเดคเตเดคเดฟเดจเดพเดฏเดฟ เดฐเตเดเดเตพ DynamoDB เดกเดพเดฑเตเดฑเดพเดฌเตเดธเดฟเตฝ เดธเดเดฐเดเตเดทเดฟเดเตเดเดฟเดเตเดเตเดฃเตเดเต เดเดจเตเดจเดฑเดฟเดฏเดพเตป เด
เดตเดถเตเดทเดฟเดเตเดเตเดจเตเดจเต. airline_tickets เดชเดเตเดเดฟเดเดฏเดฟเตฝ เดเดเดฆเตเดถเด เดเดจเดฟเดชเตเดชเดฑเดฏเตเดจเตเดจ เดกเดพเดฑเตเดฑ เด
เดเดเตเดเดฟเดฏเดฟเดฐเดฟเดเตเดเตเดจเตเดจเต:
เดคเตเดฐเตเดฎเดพเดจเด
เดเตเดฏเตเดค เดเตเดฒเดฟเดฏเตเดเต เดธเดฎเดฏเดคเตเดคเต, เดเดฎเดธเตเตบ เดเดฟเดจเดฟเดธเดฟเดธเต เด เดเดฟเดธเตเดฅเดพเดจเดฎเดพเดเตเดเดฟ เดเดฐเต เดเตบเดฒเตเตป เดกเดพเดฑเตเดฑ เดชเตเดฐเตเดธเดธเตเดธเดฟเดเดเต เดธเดฟเดธเตเดฑเตเดฑเด เดจเดฟเตผเดฎเตเดฎเดฟเดเตเดเต. Kinesis เดกเดพเดฑเตเดฑ เดธเตเดเตเดฐเตเดฎเตเดเตพ, SQL เดเดฎเดพเตปเดกเตเดเตพ เดเดชเดฏเตเดเดฟเดเตเดเต เดคเดคเตเดธเดฎเดฏ เด เดจเดฒเดฟเดฑเตเดฑเดฟเดเตเดธเต Kinesis Analytics เดเดจเตเดจเดฟเดตเดฏเตเดฎเดพเดฏเดฟ เดธเดเดฏเตเดเดฟเดเตเดเต Kinesis เดเดเดจเตเดฑเต เดเดชเดฏเตเดเดฟเดเตเดเตเดจเตเดจเดคเดฟเดจเตเดณเตเดณ เดเดชเตเดทเดจเตเดเดณเตเด เดฎเดฑเตเดฑเต AWS เดธเตเดตเดจเดเตเดเดณเตเดฎเดพเดฏเตเดณเตเดณ Amazon Kinesis-เดจเตเดฑเต เดเดเดชเตเดเดฒเตเด เดชเดฐเดฟเดเดฃเดฟเดเตเดเดชเตเดชเตเดเตเดเต.
เดฎเตเดเดณเดฟเดฒเตเดณเตเดณ เดธเดฟเดธเตเดฑเตเดฑเด เดเดเตเดเตพ เดฐเดฃเตเดเต เดคเดฐเดคเตเดคเดฟเตฝ เดตเดฟเดจเตเดฏเดธเดฟเดเตเดเต: เดตเดณเดฐเต เดฆเตเตผเดเตเดฏเดฎเตเดฑเดฟเดฏ เดฎเดพเดจเตเดตเตฝ, เดเตเดฑเดพเดซเตเด เดเตเดกเดฟเตฝ เดจเดฟเดจเตเดจเตเดณเตเดณ เดตเตเดเดคเตเดคเดฟเดฒเตเดณเตเดณ เดเดจเตเดจเต.
เดเดฒเตเดฒเดพ เดชเตเดฐเตเดเดเตเดฑเตเดฑเต เดธเตเดดเตโเดธเต เดเตเดกเตเด เดฒเดญเตเดฏเดฎเดพเดฃเต
เดฒเตเดเดจเด เดเตผเดเตเด เดเตเดฏเตเดฏเตเดจเตเดจเดคเดฟเตฝ เดเดจเดฟเดเตเดเต เดธเดจเตเดคเตเดทเดฎเตเดฃเตเดเต, เดจเดฟเดเตเดเดณเตเดเต เด เดญเดฟเดชเตเดฐเดพเดฏเดเตเดเตพเดเตเดเดพเดฏเดฟ เดเดพเตป เดชเตเดฐเดคเตเดเตเดทเดฟเดเตเดเตเดจเตเดจเต. เดเตเดฐเดฟเดฏเดพเดคเตเดฎเดเดฎเดพเดฏ เดตเดฟเดฎเตผเดถเดจเด เดเดพเตป เดชเตเดฐเดคเตเดเตเดทเดฟเดเตเดเตเดจเตเดจเต.
เดเดพเตป เดจเดฟเดจเตเดจเต เดตเดฟเดเดฏเด เดเดเตเดฐเดนเดฟเดเตเดเตเดจเตเดจเต!
เด
เดตเดฒเดเดฌเด: www.habr.com