You can use Realtime Compute for Apache Flink to process and analyze data in Tablestore in real time based on your business requirements.
Background information
Realtime Compute for Apache Flink is a one-stop real-time big data analytics platform developed by Alibaba Cloud based on Apache Flink. It supports end-to-end data analytics within sub-seconds and simplifies the business development process by using standard SQL statements. Realtime Compute for Apache Flink is built with the Tablestore connector to read, write, and compute Tablestore data. For more information, see Appendix 1: Tablestore connector.
Tunnel Service is built on the Tablestore API to provide tunnels that are used to consume data in full, incremental, and differential modes. After you create a tunnel for a data table, you can perform streaming processing to consume historical and incremental data in the data table.
Scenarios
You can connect Tablestore to Realtime Compute for Apache Flink to meet the following business requirements:
Real-time data analytics and processing
Tablestore can be used as the data source of Flink jobs to collect and process large amounts of structured data in real time. This helps users monitor business data and analyze data trends in real time to meet the requirements of enterprises to respond quickly to market dynamics.
IoT data processing
The TimeSeries model of Tablestore is designed based on the characteristics of time series data. This model can be used to store and process time series data that is generated by IoT devices. You can use the real-time computing capabilities of Realtime Compute for Apache Flink to perform real-time monitoring and analytics, predictive maintenance, and intelligent decision-making. For example, you can perform vehicle trajectory analytics and environmental monitoring.
Risk monitoring in the finance industry
Financial institutions must monitor transactions in real time to identify potential risks and take appropriate measures. Realtime Compute for Apache Flink can be used to monitor transaction data streams in real time, detect anomalies (such as frequent large-sum transfers and remote logins), and write risk scores or abnormal records to Tablestore for subsequent audit and analytics.
For more information about the scenarios of Realtime Compute for Apache Flink, see Scenarios.
Billing rules
Realtime Compute for Apache Flink
Realtime Compute for Apache Flink provides two billable items: management resources and computing resources. For more information, see Billing.
Tablestore
When you use a compute engine to access Tablestore, you are charged by Tablestore for reading and writing data. After you write data to Tablestore, you are charged by Tablestore for data storage fees based on the storage usage. For more information, see Billing overview.
References
Realtime Compute for Apache Flink can use the tunnels of Tunnel Service as the source of streaming data to compute and analyze Tablestore data. For more information, see Use Realtime Compute for Apache Flink to process Tablestore data.