Beginner developers starting out with basic value filtering, string parsing, and simple conditional operations.
Filter products by price range and list catalog summaries.
Save the following raw rows locally as \`dataset.csv\` to test your pipeline:
product_id,name,category,price
p1,Laptop,Electronics,999.99
p2,Headphones,Electronics,149.99
p3,Desk Chair,Furniture,250.00
p4,Notebook,Stationery,4.99
p5,Monitor,Electronics,300.00Create a local file named \`starter.py\` and copy the following skeleton. Complete the missing transformations:
# starter.py - Product Catalog
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
def run_pipeline():
options = PipelineOptions()
with beam.Pipeline(options=options) as p:
# TODO: Parse catalog records
# TODO: Filter items >= 100
# TODO: Write to text output
pass
if __name__ == "__main__":
run_pipeline()