Answer 1

您可以尝试

df['tableName'] = df['query'].str.extract('(?i)from ([^ ]*)')

（？i）表示忽略案例。

print(df)

   id                                query tableName
0   1  select * from table1 where col1 = 1    table1
1   2       select a.columns FROM table2 a    table2

Answer 2

echo rawurldecode($desired_output);

Answer 3

在反应性中，您需要使用各种反应式操作员（汇编时间）将所有异步操作组合到流中，然后将发布者（ mono / flux ）组合在一起（订阅时间）（订阅时间） ）。您是对的，调用 subscribe 明确是一种不良习惯，应避免。 Spring Webflux订阅了现场提供的流量。

在您的代码中，您通过不链接 rmap.expire（2，TimeUnit.hours）; 来打破流量。您可以这样重写代码

private Mono<MyObject> getMyObjectFromCache(String url) {
    RMapReactive<String, String> rMap = redissonReactiveClient.getMap(url);
    return rMap.readAllMap()
            .flatMap(m ->
                    rMap.remainTimeToLive()
                            .flatMap(ttl -> {
                                final long renewalThreshold = 60 * 60 * 1000;
                                if (ttl <= renewalThreshold) {
                                    System.out.println("start expiring");
                                    // it doesn't work without subscribe()
                                    return rMap.expire(2, TimeUnit.HOURS);
                                }
                                return Mono.just(false);
                            })
                            .then(JSONObject.parseObject(JSON.toJSONString(m), MyObject.class))
            );
}

Answer 4

首先，您应该尝试阅读 docs 属性guildmember实际上具有什么，只需快速查看它，您应该能够找到 .permissions ，然后从中，您将获得此 .has 函数。因此，您的最终代码应该是

message.member.permissions.has(Permissions.FLAGS.MANAGE_MESSAGES)

Answer 5

您可以尝试 groupby 和 filter

cols = ['id', 'color']
out = (df.groupby(cols)
       .filter(lambda df: df['val'].le(3).sum() >= 3)
       .drop_duplicates(cols)[cols])

print(out)

   id color
0   1     y

Answer 6

它有助于使用不同的布局重新格式化代码，以更准确地捕获正在发生的功能，

always 
   @(a or b or ci)          // line 1
   #12                      // line 2
   {co, sum} = a + b + ci;  // line 3

第一行暂停了始终过程，直到看到一个列出的信号之一发生在时间15时。 。

第二行暂停该过程12个时间单元 在此期间，A，B和CI忽略了。

第三行在时间27（15+12）醒来，并使用A，B和CI的当前值，并将阻止分配给 {CO，SUM} 。

由于这是一个始终块，因此在分配后，它会循环回到第一行，并等待另一个更改。

Answer 7

返回 -1 ，如果在容器中找不到元素。您应该在每个字符串 word 上使用 indexof ，而不是在数组 words ：

var words = ['hello', 'sunshine', 'apple', 'orange', 'pineapple'];

var wordsWithA = words.filter(function (word) {
  return word.indexOf('a') !== -1;
});

console.log(wordsWithA);

Answer 8

不确定您正在使用哪个框架，但是fs.copyfile（）是Node.js https://nodejs.org/api/fs.html#fscopyfilesrc-dest-mode-callback

Answer 9

J块和 k块都是2列宽，但右列为0px宽。对于 l块：下排高0px。

在第一行中添加3个带有东西的单元格，您会发现J/K块跨2列延伸。

另外，Edge和Chrome使用相同的渲染引擎，因此无论是对还是错，输出都会看起来相同。如果您想查看其他引擎的输出，请使用Firefox或Safari。

Answer 10

您存在的问题是，使用 .suffix 数组不是从0开始。 7] 。

[ 。

在集合末端终止的子序列，最大值元素。

如果您将描述读为 subsequence ：

代表该集合元素连续子范围的集合。子序列与原始集合共享指数。

操场的完整示例：

let array = [1,2,3,4,5,6,7,8,9,10]
let suffixArray = array.suffix(5) // [6,7,8,9,10]
let prefixArray = array.prefix(5) // [1,2,3,4,5]
var newSuffixArray: [Int] = []
for i in suffixArray {
    newSuffixArray.append(i)
}

print(suffixArray[7]) // 8
print(newSuffixArray[2]) // 8
print(prefixArray[2]) // 3

Answer 11

尝试 fuzzyjoin ：

我们可以基于模糊字符串匹配其列的 DF1 df2 。

使用max_dist，我们可以定义加入的最大距离，

请参见：？stringdist_left_join

library(dplyr)
library(fuzzyjoin)

fuzzyjoin::stringdist_left_join(x=df1, y=df2, max_dist =.35, by='test', method ='jaccard', distance_col = "dist")

   test.x test.y      dist
1   SNTM1   <NA>        NA
2  STTTT2   <NA>        NA
3   STOLA   <NA>        NA
4   STOMQ  STOMQ 0.0000000
5    STR2  STR25 0.2000000
6  SUPTY1   <NA>        NA
7  TBNHSG   <NA>        NA
8   TEYAH   <NA>        NA
9  TMEIL1 TMEIL1 0.0000000
10 TMEIL2 TMEIL1 0.2857143
11 TMEIL3 TMEIL1 0.2857143
12   TNIL   <NA>        NA
13  TREUK   <NA>        NA
14   TTRK   <NA>        NA
15  TRRFK   <NA>        NA
16  UBA52   <NA>        NA
17  YIPF1  YIPF1 0.0000000

Answer 12

不幸的是，Node.js不支持ES6的导入。

为了完成您要做的事情（导入Express模块​​），此代码

var express = require("express");

也应足够，请确保您已通过运行安装了Express，

$ npm install express

请参见 node.js文档有关学习node.js的更多信息。

Answer 13

桑德罗的答案应该解决您的问题。对于使用实时桌子摄入JSON文件，您可以在某些用例中查看本文“ rel =“ nofollow noreferrer”> https://medium.com/@chaobioz/create-delta-live-tables-dlt-dlt-dlt-dynamisaly-with-pyspark-e06a718199c8

同样也可以生产，最好将自动装载机作为生产出色地。

Answer 14

在这种情况下，您不需要用 .nodes 切碎XML，因为您可以将其纯粹用Xquery

WITH XMLNAMESPACES 
(
    DEFAULT 'http://www.oceanwide.com/ZObject/2014',
    'http://www.w3.org/2001/XMLSchema' as xs,
    'http://www.w3.org/2001/XMLSchema-instance' as xsi
)
SELECT ID
    , Amount = customdata.value('sum(
      ZObject/Attribute/ZObject/Attribute/ZObject
      [
        Attribute[@Name = "ClaimPayment.TypeCode"]
        /ZObject/Value[text() = "Indemnity"]
      ]/Attribute[@Name = "ClaimPayment.Amount"]
      /ZObject/Value/text()
    )', 'decimal(18,9)')
FROM @tbl AS t;

ID	金额
总结1	100000.000000000

db＆lt;

Answer 15

recurringjob.addorupdate 您正在调用的过载接受 expression＆lt; func＆lt; task＆gt;＆gt; 。那是代表返回任务的调用的表达树。

不幸的是， recurringjob.addorupdate 要求该表达式树表示方法调用 - 它调用 job.fromexpression ，最终以

如下所示，您可以将调用包裹在方法调用中 - 我不知道它是否会真正起作用...您可能会发现您最终会得到很多名称为“执行”的作业。

private void AddTrigger(string triggerId, Frequency frequency, 
                        Func<Frequency, Task> trigger)
{
    var wrapper = new TriggerWrapper(() => trigger(frequency));
    RecurringJob.AddOrUpdate(triggerId, () => wrapper.Execute(), Cron.Daily());
}

private class TriggerWrapper
{
    private Func<Task> func;

    internal TriggerWrapper(Func<Task> func) => this.func = func;

    public Task Execute() => func();
}