首页 > 解决方案 > 添加另一个节点后 Cloud Composer 抛出 InvalidToken

问题描述

我最近在生产气流中添加了一些新的 DAG,因此决定扩大 Composer 池中的节点数量。这样做后我得到了错误:Can't decrypt _val for key=<KEY>, invalid token or value. 现在,每个使用变量的 DAG 都会发生这种情况。它也不是同一个键,它取决于 DAG 需要哪些变量。

我立即将 Composer 缩减为 3 个节点,但问题仍然存在。

我尝试重新保存所有变量,在 UI 中重新创建它们(表示它们都是有效的),在 CLI 中重新创建它们(列出invalid每个变量)。

我还尝试更新配置以尝试重新启动服务器,并手动停止 VM 实例。

Composer 似乎也否定了更新 Fernet Key 的能力,所以我不能尝试使用新的。出于某种原因,作曲家分配的永久物现在似乎无效。

除了重建环境之外,还有什么其他方法可以解决这个问题吗?

标签: google-cloud-platformairflowgoogle-cloud-composer

解决方案


我设法通过添加一个新的 python 包来解决这个问题。似乎添加一个包是真正“重启”环境的唯一方法。重新启动完成后,我的所有变量和连接都无效,但我能够将它们重新添加,而不必重新创建整个环境。

听说过这个问题:根据谷歌的说法,Composer 为环境创建了一个自定义图像,并将一个图像传递给每个节点,如果在缩放过程中损坏了,那么修复它的唯一方法是添加一个新的 python 包,以便它重建图片。顺便说一句,Composer 的 1.3.0 版本要好得多,因为调度程序每 10 分钟重新启动一次,这应该可以解决我遇到的一些后面的问题。


推荐阅读