Source: Distributed optimization with Cloud Dataflow from Google Cloud
Optimization problems aim to find values for parameters of a system, such that a given aspect (the objective) of the problem is maximized (or minimized). When some of the parameters of the system are restricted to a discrete set of values rather than a range, applying algorithms such as gradient descent directly can be problematic. This type of optimization problem is typically called a mixed integer programs, and the most straightforward method to find a solution is to perform a search over the grid formed by the discrete values:
Naturally, the grid grows considerably in size if the number of discrete parameters increases: as a consequence, the computational demands grow significantly when a large number of continuous optimization problems need to be solved. Fortunately, this pattern allows distributing the workload over several nodes. As shown below, Cloud Dataflow offers a very flexible and serverless way to accomplish this: the Python SDK consists of transforms that allow simple integration with the rich ecosystem of data and scientific processing Python libraries including NumPy, SciPy, Pandas, or even TensorFlow.
Consider a set of crops that will need to be harvested at the end of the season, and which must be distributed optimally over a set of available greenhouses. Once the crops have been assigned to a greenhouse, some production parameters can be tuned for each greenhouse to increase the efficiency (minimize cost and maximize yield). The goal is to map all the crops across the greenhouses to obtain maximal efficiency, given transportation costs and other constraints.
It’s possible to represent the assignment of crops to greenhouses as discrete parameters: each crop is in one greenhouse. A single configuration of all crops assigned to a greenhouse is referred to as mapping and represented as a list. Each element corresponds to a single crop assigned to a greenhouse:
M=[C,C,A,…,B,C]
The efficiency of a greenhouse can be simulated as a function of continuous parameters, and can be optimized with gradient descent.
For a problem with N crops and M greenhouses, M^{N} mappings can be formed. For each mapping, the production parameters for M greenhouses need to be solved, meaning the upper bound for the number of gradient descent problems equals M^{(N+1)}, assuming production of each crop be possible in every greenhouse.
The Apache Beam pipeline is structured as follows:
Generate all possible mappings of crops to greenhouses
For the greenhouses in each mapping, optimize the production parameters
Include transportation costs
Aggregate by mapping and sum the costs
Aggregate all mappings and select the mapping with minimal cost
The starting point for your pipeline is a comma separated (CSV) file, with each line representing a crop. The first column is the crop name, the second the total amount to be produced expressed in tons, followed by columns representing the transportation cost per unit if the crop were to be produced in that greenhouse. An empty column indicates the crop can not be produced in the specified greenhouse.
This information is used to produce all possible lists describing the mappings, which are further transformed into a PCollection
of the following data structure, representing a single optimization task to be solved with gradient descent:
((<mapping ID>, <greenhouse>), [(crop, quantity),...])
Using a ParDo
, these tasks are solved with a standard solver from SciPy:
Thus, the Python SDK for Dataflow provides a simple interface to integrate the solver, with no additional requirements in terms of implementation. This example uses SciPy, but it is even possible to construct a TensorFlow graph and run computations with it inside a ParDo. Other transforms of the SDK such as Map, sideinputs, and GroupBy provide a flexible way to process and organize the input for the solver.
Additionally, these transforms are similar to functional programming constructs in Python, which might help you find them familiar. As a very large number of these tasks need to be executed, it makes sense to distribute the workload. Cloud Dataflow automatically takes care of this in a serverless manner, which means there’s not need to manage infrastructure and install distributed frameworks. Additionally, the amount of hardware available becomes less a limiting factor: even for large grids, Dataflow will automatically scale up to the suitable number of computing nodes to parallelize execution.
Summary
The Beam paradigm offers a very flexible way to parallelize and scale optimization workloads that can be split up into many tasks in a serverless manner with no need to manage infrastructure. Mixed integer programming is a prime example of this class of problems. Even our limited example requires us to evaluate a large solution space. Cloud Dataflow’s Python SDK provides transforms familiar to most Python developers, and permits easy integration with the rich ecosystem of dataprocessing and scientificprocessing libraries.
The exhaustive search over the discrete solution grid we discussed in this example has its limits: the size may quickly grow beyond what is feasible, even with the scalability offered by Dataflow. Note, however, that the same approach described in this blog post can be used to efficiently scale the computation of fitness values for an entire generation in the context of populationbased algorithms such as genetic algorithms and evolutionary strategies. These algorithms can be used as more efficient alternatives to search through the discrete grid.
除非特别声明，此文章内容采用知识共享署名 3.0许可，代码示例采用Apache 2.0许可。更多细节请查看我们的服务条款。
Tags:
Cloud
最新文章

DACH businesses embrace Google Cloud for digital transformation

3 steps to detect and remediate security anomalies with Cloud Anomaly Detection

Increasing the scaling limits of the Firebase Realtime Database

An Inside Look at Flood Forecasting

Get smart about preparing your app for OAuth verification

Worldwide Opportunities on Organic Farms uses Google Maps Platform to build communities that care about ecological farming

Google Cloud Firewall Rules Logging: How and why you should use it

Virtual display devices for Compute Engine now GA

How Trade Me reduces IT maintenance with the help of Grab and Go Chromebooks

Project Ihmehimmeli: Temporal Coding in Spiking Neural Networks
最多查看

如何选择 compileSdkVersion, minSdkVersion 和 targetSdkVersion (23,867)

谷歌招聘软件工程师 (22,072)

Google 推出的 31 套在线课程 (21,902)

Seti UI 主题: 让你编辑器焕然一新 (13,612)

Android Studio 2.0 稳定版 (9,272)

Android N 最初预览版：开发者 API 和工具 (8,004)

像 Sublime Text 一样使用 Chrome DevTools (6,218)

用 Google Cloud 打造你的私有免费 Git 仓库 (5,950)

Google I/O 2016: Android 演讲视频汇总 (5,573)

面向普通开发者的机器学习应用方案 (5,449)

生还是死？Android 进程优先级详解 (5,163)

面向 Web 开发者的 Sublime Text 插件 (4,289)

适配 Android N 多窗口特性的 5 个要诀 (4,270)

参加 Google I/O Extended，观看 I/O 直播，线下聚会！ (3,594)
© 2019 中国谷歌开发者社区  ChinaGDG