質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.48%
Amazon Kinesis

Amazon Kinesisは、リアルタイムで動画や音声、IoT機器といったストリーミングデータを収集・処理・分析する完全マネージド型分析サービスです。インサイトを適時に取得できるので迅速な対応が可能になります。

Q&A

0回答

588閲覧

Kubelessを使ってkinesisからデータをgetしたい。

pokemonta

総合スコア170

Amazon Kinesis

Amazon Kinesisは、リアルタイムで動画や音声、IoT機器といったストリーミングデータを収集・処理・分析する完全マネージド型分析サービスです。インサイトを適時に取得できるので迅速な対応が可能になります。

0グッド

0クリップ

投稿2021/05/14 07:52

編集2021/06/01 12:54

kinesisへのputを検知するコントローラを
kinesistriggers.kubeless.ioにて構築しました。

これは、kinesisにデータを書き込まれると
ストリーム・シャードに紐づいている関数(python)が実行されるものです。
リンク内容

実際にkinesisにデータを書き込んだのですが、
関数(python)が実行されません。

このpythonは、print(event)するだけのもので
kubectl logs hello-xxxでその内容がログに出力される想定です。

python

1def hello(event, context): 2 print(event) 3 return event['data']

EC2は、十分なロールが付与されています。

設定自体は、うまくいってそうなんですけど、まったく原因がわかりません。
対応方法をご教示願います。

cmd

1■kubeless function 2NAME NAMESPACE HANDLER RUNTIME DEPENDENCIES STATUS 3hello default test.hello python3.7 1/1 READY 4 5■Kubelessトリガー 6kubeless trigger kinesis list 7NAME NAMESPACE REGION STREAM SHARD FUNCTION NAME 8test-trigger default ap-northeast-1 k8stest shardId-999 hello 9 10■kinesisシャードの設定 11aws kinesis describe-stream --stream-name k8stest 12{ 13 "StreamDescription": { 14 "KeyId": null, 15 "EncryptionType": "NONE", 16 "StreamStatus": "ACTIVE", 17 "StreamName": "k8stest", 18 "Shards": [ 19 { 20 "ShardId": "shardId-999" 21 } 22 ], 23 24 } 25}

権限周りが怪しいと思っています

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

まだ回答がついていません

会員登録して回答してみよう

アカウントをお持ちの方は

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.48%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問