写一个python 代码，每隔一秒自动向文件夹里写入一个包含随机单词的文件，写一个spark streaming的代码，监控这个文件，统计wordcount

以下是Python代码，可以每隔一秒钟向指定文件夹中写入一个包含随机单词的文件：

import time
import random
import string
import os

# 指定文件夹路径
folder_path = '/path/to/folder/'

# 生成随机单词
def generate_word(length):
    letters = string.ascii_lowercase
    return ''.join(random.choice(letters) for i in range(length))

while True:
    # 生成文件名
    filename = generate_word(10) + '.txt'
    # 拼接文件路径
    file_path = os.path.join(folder_path, filename)
    # 写入文件
    with open(file_path, 'w') as f:
        f.write(generate_word(100))
    # 等待1秒钟
    time.sleep(1)

以下是Spark Streaming代码，可以监控指定文件夹中的文件，统计单词出现的次数：

from pyspark import SparkContext
from pyspark.streaming import StreamingContext
import os

# 指定文件夹路径
folder_path = '/path/to/folder/'

# 创建SparkContext和StreamingContext
sc = SparkContext("local[2]", "WordCount")
ssc = StreamingContext(sc, 1)

# 创建DStream
lines = ssc.textFileStream(folder_path)

# 统计单词出现的次数
word_counts = lines.flatMap(lambda line: line.split(" ")) \
                   .map(lambda word: (word, 1)) \
                   .reduceByKey(lambda a, b: a + b)

# 打印结果
word_counts.pprint()

# 启动StreamingContext
ssc.start()
ssc.awaitTermination()