使用Python的write()函数将数据写到Hadoop集群

在Python中可以使用hdfs库来连接和操作Hadoop集群。以下是一个使用write()函数将数据写入Hadoop集群的示例代码：

from hdfs import InsecureClient

# 创建一个Hadoop集群的连接
client = InsecureClient('http://<HADOOP_MASTER_IP>:<HADOOP_PORT>', user='<HADOOP_USERNAME>')

# 定义要写入的数据
data = "Hello, Hadoop!"

# 将数据写入到Hadoop集群
with client.write('<HADOOP_FILE_PATH>') as writer:
    writer.write(data)

# 关闭Hadoop集群的连接
client.close()

上述代码中，我们首先使用Hadoop集群的URL和用户名来创建一个InsecureClient对象。然后，我们定义要写入的数据以及要写入到Hadoop集群的文件路径。接下来，我们使用write()函数创建一个文件写入器，并使用with语句来自动管理打开和关闭文件。最后，我们使用write()函数将数据写入文件。注意，如果指定的文件路径不存在，Hadoop集群将自动创建该文件。

需要替换实际的Hadoop集群的IP地址、端口号、用户名和文件路径来正确运行上述代码。同时，还需要确保在运行代码之前已安装了hdfs库。可以使用以下命令安装该库：

pip install hdfs

使用上述代码示例，您可以将数据成功写入Hadoop集群。