在 Dask DataFrame 中为每个分区创建具有特定值的新列

Question

我有两个分区数相同的 Dask DataFrame。

第一个分区的每个分区都有几列和几行（因此 Pandas DataFrame），但两个分区之间的行数可能不同（而不是列）。 第二个 Dask DataFrame 具有完全相同的分区数，但只有 1 个值。 我正在尝试通过合并、分区到分区来合并这两个 Dask DataFrame，如下所示。

Dask DataFrame N°1（玩具示例）：

Dask DataFrame N°2（每个分区只有 1 个值，因此只有 1 列）：

我的目标是获得这样的 Dask Dataframe：

我用

Dask.assign()

试过

Dask.map_partitions()

但没有成功。

你有什么想法可以有效地做到这一点吗？

问候。

rmarion37