流式开发实例：map 脚本内容

  1. #!/usr/bin/python
  2. import sys
  3. for eachLine in sys.stdin: t- 从标准输入获取数据
  4. eachLine = eachLine.strip()
  5. Seg = eachLine.split('|)t- 使用|` 分隔各个字段
  6. if len(Seg) == 19 and Seg[1] == 'rpt_cad' and Seg[6] != '': t- 判断字段数量和值，符合条件则继续
  7. ad_id = Seg[6]
  8. print '%st%d' % (ad_id, 1) t- 将结果打印到标准输出
  9. else: t- 不符合条件则忽略

文件名：ad_day_pv_map.py