小编Tsu*_*ume的帖子

什么是默认的Akka调度程序配置值?

在Akka文档中,它指出如果未配置调度程序,将使用默认调度程序.默认调度程序的属性是什么,即parallelism-min,parallelism-factor,parallelism-max等?

java scala dispatcher akka

29
推荐指数
1
解决办法
1万
查看次数

Akka事件总线教程

关于如何在akka中使用事件总线,有没有很好的教程/解释?我已经阅读了Akka文档,但我发现很难理解如何使用事件总线

scala akka event-bus

16
推荐指数
2
解决办法
9025
查看次数

如何在 Airflow 中使用配置文件

在 Airflow 中,我们创建了几个 DAGS。其中一些共享公共属性,例如从中读取文件的目录。目前,这些属性被列为每个单独的 DAG 中的一个属性,这在未来显然会成为问题。假设目录名称要更改,我们必须进入每个 DAG 并更新这段代码(甚至可能丢失一个)。

我正在研究创建某种配置文件,该文件可以解析为 Airflow 并在需要某个属性时由各种 DAGS 使用,但我似乎找不到任何有关如何执行此操作的文档或指南。我能找到的大部分是关于设置连接 ID 的文档,但这不符合我的用例。

我的帖子的问题是,是否可以执行上述场景以及如何执行?

提前致谢。

configuration airflow

5
推荐指数
1
解决办法
5137
查看次数

标签 统计

akka ×2

scala ×2

airflow ×1

configuration ×1

dispatcher ×1

event-bus ×1

java ×1