spark 数据写入mysql，乱码怎么处理

如果您在将数据从 Spark 中写入 MySQL 数据库时遇到乱码问题，可能是由于字符集不匹配所致。可以尝试以下两种方法解决：

1. 指定字符集
在 Spark 中，可以通过设置 JDBC 连接字符串来指定字符集，例如：

jdbc:mysql://localhost:3306/db_name?useUnicode=true&characterEncoding=UTF-8

这样，数据就会以 UTF-8 编码写入 MySQL 数据库中。

2. 转码
在 Spark 中，可以使用 `map` 函数将数据转码，例如将 UTF-8 编码转为 GBK 编码：

df = df.map(lambda x: [x[0], x[1].encode('gbk', 'ignore')]).toDF(['col1', 'col2'])

这样，数据就会以 GBK 编码写入 MySQL 数据库中。

需要注意的是，如果数据中存在 Emoji 等特殊字符，可能会导致转码错误，建议先将特殊字符过滤或替换。