python KCL 连接到运动流时出现异常
exception when python KCL connects to kinesis stream
我正在尝试将 kinesis 集成到 spark streaming 中，为此我正在使用 python 和 KCL。从 kinesis
读取时，我大多数时候都会遇到这个异常
'utf8' 编解码器无法解码位置 940 中的字节 0xf1：无效的连续字节
谁能告诉我如何解决这个问题
这就是我创建流的方式
kinesisStream = KinesisUtils.createStream(ssc, APPLICATION_NAME, STREAM_NAME, ENDPOINT, REGION_NAME, INITIAL_POS, CHECKPOINT_INTERVAL, awsAccessKeyId =AWSACCESSID, awsSecretKey=AWSSECRETKEY)
您应该检查以确保进入流的数据是 UTF-8。
尝试将 Latin-1 (ISO-8859-1) 解码为 UTF-8 可能是此类错误的一个原因。
我正在尝试将 kinesis 集成到 spark streaming 中，为此我正在使用 python 和 KCL。从 kinesis
读取时，我大多数时候都会遇到这个异常'utf8' 编解码器无法解码位置 940 中的字节 0xf1：无效的连续字节
谁能告诉我如何解决这个问题 这就是我创建流的方式
kinesisStream = KinesisUtils.createStream(ssc, APPLICATION_NAME, STREAM_NAME, ENDPOINT, REGION_NAME, INITIAL_POS, CHECKPOINT_INTERVAL, awsAccessKeyId =AWSACCESSID, awsSecretKey=AWSSECRETKEY)
您应该检查以确保进入流的数据是 UTF-8。
尝试将 Latin-1 (ISO-8859-1) 解码为 UTF-8 可能是此类错误的一个原因。