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}
権限周りが怪しいと思っています
あなたの回答
tips
プレビュー