1

キネシスをスパーク ストリーミングに統合しようとしています。そのために、Python と KCL を使用しています。キネシスから読み取るときに、ほとんどの場合、この例外が発生します

「utf8」コーデックは位置 940 のバイト 0xf1 をデコードできません: 無効な継続バイト

誰かこの問題を解決する方法を教えてください これが私がストリームを作成する方法です

kinesisStream = KinesisUtils.createStream(ssc, APPLICATION_NAME, STREAM_NAME, ENDPOINT, REGION_NAME, INITIAL_POS, CHECKPOINT_INTERVAL, awsAccessKeyId =AWSACCESSID, awsSecretKey=AWSSECRETKEY)
4

1 に答える 1

1

ストリームに入るデータが UTF-8 であることを確認する必要があります。

Latin-1 (ISO-8859-1) を UTF-8 としてデコードしようとすると、このタイプのエラーの原因の 1 つになることがあります。

于 2016-03-05T04:30:48.647 に答える