我试图读取一个JSON文件通过apache光束在python和应用一些数据质量规则。目前我使用beam.io. ReadFromText读取每个json行，并使用一些函数来修改数据。什么是更好的方法来读取JSON数据并修改它们？

(p
  | 'Getdata' >> beam.io.ReadFromText(input)
  | 'filter_name' >> beam.FlatMap(lambda line: dq_name(line))
  | 'filter_phone' >> beam.FlatMap(lambda line: dq_phone(line))
  | 'filter_zip' >> beam.FlatMap(lambda line: dq_zip(line))
  | 'filter_address' >> beam.FlatMap(lambda line: dq_city(line))
  | 'filter_website' >> beam.FlatMap(lambda line: dq_website(line))
  | 'write' >> beam.io.WriteToText(output_prefix)  )

注意：我对此相当陌生，如果我目前的方法看起来太粗制滥造，我很抱歉。