python中的Apache Beam：如何触发空窗口警报
我在用Python编写的Apache Beam管道中处理分析命中。我使用的是10分钟的FixedWindows，当窗口为空时，我希望触发警报（例如，使用Cloud Pub/sub）。到目前为止，我所做的是：
ten_min_windows = day_hits | '10MinutesWindows' >> beam.WindowInto(
beam.window.FixedWindows(10 * 60))
ten_min_alerts = (ten_min_windows
| 'CountTransactions10Min' >> beam.CombineGlobally(count_transactions).without_defaults()
| 'KeepZeros10Min' >> beam.Filter(keep_zeros)
| 'ConvertToAlerts10Min' >> beam.ParDo(ToAlert()))
共有1个答案
例如，您可以使用metrics.counter来监视Stackdriver中处理的元素数量。
从那里，您可以根据自己的规则，从您喜欢的监视工具设置警报。
-
我有flink stream，我在某个时间窗口上计算一些事情，比如说30秒。 这里发生的事情是，它给我的结果，我以前的窗口聚合以及。 假设前30秒我得到结果10。 接下来的三十秒我想要新的结果，而不是我得到最后一个窗口的结果新的等等。 因此，我的问题是如何为每个窗口获得新的结果。
-
我有这个脚本： HTML中的用法： 由于某些原因，它的工作，如果页面重新加载一半，但不，它没有开火，在它工作之前，所以我不知道发生了什么。我在wordpress网站上使用这个。
-
问题内容： 我已经在窗口调整大小上注册了一个触发器。我想知道如何触发事件被调用。例如，当隐藏一个div时，我希望调用触发函数。 我发现可以触发该功能，但是还有其他解决方案吗？ 问题答案： 在可能的情况下，我更喜欢调用函数而不是调度事件。如果您可以控制要运行的代码，则此方法效果很好，但是如果您不拥有该代码，请参见下文。 在此示例中，您可以在不调度事件的情况下调用该函数。 在现代浏览器中，您可以使用以
-
我正在尝试在我的Flink作业中使用事件时间，并使用来提取时间戳并生成水印。但是我有一些输入Kafka具有稀疏流，它可以长时间没有数据，这使得中的根本没有调用。我可以看到数据进入函数。 我已经设置了getEnv（）。getConfig（）。设置自动水印间隔（1000L） 我尝试过 还有会话窗口 所有的水印都显示没有水印，我怎么能让Flink忽略这个没有水印的东西呢？
-
我的数据流来自一个定制的SourceFunction，它以确定性的顺序发出窗口大小的字符串序列。其目的是基于EventTime在keyedstream上创建滑动窗口，以便对累积的字符串进行处理。为了分配EventTime和水印，我将一个带有PeriodicWatermarks的赋值器附加到流。滑动窗口使用自定义ProcessWindowFunction进行处理。 My AssignerWithPe
-
当我使用 flink 事件时间窗口时，窗口只是不触发。如何解决问题，有没有办法调试？