learning/prompts/code-generation/09_io_avro.md

Prompt:
Write the Python code to read data from Apache Avro files using Apache Beam.

Response:
Your Apache Beam pipeline can read data from [Apache Avro](https://avro.apache.org/) files using the [AvroIO connector](https://beam.apache.org/releases/pydoc/current/apache_beam.io.avroio.html).

```python
import logging

import apache_beam as beam
from apache_beam import Map
from apache_beam.io.avroio import ReadFromAvro
from apache_beam.options.pipeline_options import PipelineOptions


def run(argv=None):

  class ReadAvroOptions(PipelineOptions):

    @classmethod
    def _add_argparse_args(cls, parser):
      parser.add_argument(
          "--path",
          help="GCS path to Avro file")

  options = ReadAvroOptions()

  with beam.Pipeline(options=options) as p:

    (p | "ReadAvro" >> ReadFromAvro(options.path)
       | Map(logging.info))


if __name__ == "__main__":
  logging.getLogger().setLevel(logging.INFO)
  run()
```

The `ReadAvroOptions` class is used to define the command-line argument `--path`, which specifies the path to the Avro file. This code uses [pipeline options](https://beam.apache.org/documentation/patterns/pipeline-options/) for the required `path` argument.

The code creates an Apache Beam pipeline using the `ReadAvroOptions` class to set the Avro file path and the [`ReadFromAvro` transform](https://beam.apache.org/releases/pydoc/current/apache_beam.io.avroio.html#apache_beam.io.avroio.ReadFromAvro) to read data from the file.