PQ - Function.InvokeAfter() - 实际延迟

Question

正在尝试计算 InvokeAfter 函数执行之间的实际延迟。

函数应该每秒触发五次

index  delay now
0      0     18:47:33
1      0     18:47:33
2      0     18:47:33
3      0     18:47:33
4      0     18:47:33
5      1     18:47:34
6      1     18:47:34
7      1     18:47:34
8      1     18:47:34
9      1     18:47:34
10     2     18:47:35
11     2     18:47:35
12     2     18:47:35
13     2     18:47:35
14     2     18:47:35
...

但是我明白了

第real_delay列是这一行和前一行的区别

代码

let
    t = Table.FromList({0..19}, Splitter.SplitByNothing()),
    delay = Table.AddColumn(t, "delay", each Number.IntegerDivide([Column1], 5)),
    InvokeAfter = Table.AddColumn(delay, "InvokeTimeNow", each Function.InvokeAfter(
        ()=>DateTime.Time(DateTime.LocalNow()), #duration(0,0,0,[delay]))
    ),
    real_delay = Table.AddColumn(InvokeAfter, "real_delay", each try InvokeAfter{[Column1=[Column1]-1]}[InvokeTimeNow]-[InvokeTimeNow] otherwise "-")
in
    real_delay

代码有什么问题？或者也许使用 InvokeAfter 函数？？？

Answer 1

每秒 5 次意味着每次调用您应该等待 (second / 5) = 0.2 小数秒。

如果您运行此代码：

let
    t = Table.FromList({0..19}, Splitter.SplitByNothing()),
    delay = Table.AddColumn(t, "delay", each 0.2),
    InvokeAfter = Table.AddColumn(delay, "InvokeTimeNow", each Function.InvokeAfter(
        ()=>DateTime.Time(DateTime.LocalNow()), #duration(0,0,0,[delay]))
    ),
    real_delay = Table.AddColumn(InvokeAfter, "real_delay", each try InvokeAfter{[Column1=[Column1]-1]}[InvokeTimeNow]-[InvokeTimeNow] otherwise "-")
in
    real_delay

您会看到该函数每秒被调用大约 5 次。

Answer 2

== 解决方案 ==

这是我自己的解决方案。一个令人惊讶的，我认为...

新代码

let
    threads=5,
    t = Table.FromList({0..19}, Splitter.SplitByNothing()),
    delay = Table.AddColumn(t, "delay", each if Number.Mod([Column1], threads)=0 and [Column1]>0 then 1 else 0),
    InvokeAfter = Table.AddColumn(delay, "InvokeTimeNow", each Function.InvokeAfter(()=>DateTime.Time(DateTime.LocalNow()), #duration(0,0,0,[delay]))),
    real_delay = Table.AddColumn(InvokeAfter, "real_delay", each try InvokeAfter{[Column1=[Column1]-1]}[InvokeTimeNow]-[InvokeTimeNow] otherwise "-")
in
    real_delay

最初的想法是多线程解析。由于同时连接有一些限制，我不得不适应。

我认为有一个 "null-zero-start" 时刻，之后调用函数 - 计算单元格的时刻（所有单元格几乎同时）。第二个参数表示在此起点之后的延迟。但它似乎累积了所有延迟。非常奇怪的行为，恕我直言...

所以我解决了问题，但还是不明白为什么=)

PQ - Function.InvokeAfter() - 实际延迟

PQ - Function.InvokeAfter() - real delay

powerbi

powerquery

代码

== 解决方案 ==

新代码