随着“全面二孩”政策落地、居民可支配收入稳步增加等因素的刺激，中国的母婴消费市场正迎来黄金时代。与此同时，随着国民消费升级90后宝爸、宝妈人数剧增，消费需求与消费理念都发生了巨大的变化。据罗兰贝格最新公布的报告预计，已经经过了16个年头发展的母婴行业，到2020年，整体规模将达到3.6万亿元，2016-2020年复合增速高达17%,行业前景看起来一片光明。如此大好形势下，母婴人群在母婴消费上有什么特点？消费最高的项目是什么？
本场景将以阿里云实时计算Flink版为基础，使用Flink自带的 MySQL Connector连接RDS云数据库实例、Elasticsearch Connector连接 Elasticsearch 检索分析服务实例，并以一个淘宝母婴订单实时查询的例子尝试上手Connector的数据捕获、数据写入等功能。
本场景中订单和婴儿信息存储在MySQL中，对于订单表，为了方便进行分析，我们让它关联上其对应的婴儿信息，构成一张宽表，使用Flink实时把它写到Elasticsearch中；另一方面数据经过分组聚合后，计算出订单数量和婴儿出生的关系，实时把它写到Elasticsearch中并展示到Kibana大屏中。
按步骤完成本次实验后，您将掌握的知识有：
- 使用Flink实时计算平台创建并提交作业的方法；
- 编写基于Flink Table API SQL语句的能力；
- 使用MySQL Connector对数据库进行读取的方法；
- 使用Elasticsearch Connector对数据库进行写入的方法。
背景知识
本场景主要涉及以下云产品和服务：
阿里云实时计算 Flink 版是一种全托管 Serverless 的 Flink 云服务，开箱即用，计费灵活。具备一站式开发运维管理平台，支持作业开发、数据调试、运行与监控、自动调优、智能诊断等全生命周期能力。100% 兼容 Apache Flink，支持开源 Flink 平滑迁移上云，核心企业级增强 Flink 引擎较开源 Flink 有约两倍性能的提升。拥有 Flink CDC、企业级复杂事件处理（CEP）等企业级增值功能，并内置丰富上下游连接器，助力企业构建高效、稳定和强大的实时数据应用。
云数据库 RDS（Relational Database Service，简称 RDS）是一种稳定可靠、可弹性伸缩的在线数据库服务。基于阿里云分布式文件系统和 SSD 盘高性能存储，RDS 支持 MySQL、SQL Server、PostgreSQL、PPAS 和 MariaDB 引擎，提供了容灾、备份、恢复、监控、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。
阿里云 Elasticsearch 致力于打造基于开源生态的、低成本、场景化的云上 Elasticsearch 解决方案，源于开源，又不止于开源。基于云上超强的计算和存储能力，以及在集群安全和运维领域积累的技术经验，阿里云 Elasticsearch 不仅支持集群一键部署、弹性伸缩、智能运维和各类内核引擎优化，还提供了迁移、容灾、备份和监控等全套解决方案。
