小编Iva*_*ali的帖子

在 Rust 中，有没有办法在使用标准测试库运行所有测试后（即在cargo test.

我不打算在每次测试后运行拆卸功能，因为它们已在这些相关帖子中讨论过：

• 如何在 Rust 中运行任何测试之前运行设置代码？
• 如何为集成测试初始化​​记录器？))

这些讨论了运行的想法：

• 每次测试前的设置
• 每次测试前拆卸（使用std::panic::catch_unwind）
• 在所有测试之前设置（使用std::sync::Once）

一种解决方法是环绕cargo test调用的 shell 脚本，但我仍然很好奇上述方法是否可行。

在Python调试器中是否可以await任意调用async函数？

说我在某些main.py文件中有以下代码：

import asyncio

async def bar(x):
    return x + 1

async def foo():
    import ipdb; ipdb.set_trace()

asyncio.run(foo())

现在，我想bar()在调试器中测试带有某些参数的调用以测试结果。发生以下情况：

$ python3 main.py
> /Users/user/test/main.py(8)foo()
      7     import ipdb; ipdb.set_trace()
----> 8     return None
      9

ipdb> bar(1)
<coroutine object bar at 0x10404ae60>
main.py:1: RuntimeWarning: coroutine 'bar' was never awaited
  import asyncio
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
ipdb> await bar(1)
*** SyntaxError: 'await' outside function

当然，我可以通过在自己的x = await bar(1)之上 …

我想用一种方式来解释这个问题是为什么HTTP不能只使用UDP？HTTP明确要求TCP提供哪些特定功能？

作为这个问题的后续,我仍然对如何正确使用CXF-RS组件感到困惑.

我很困惑为什么我们需要<cxf:rsServer>用于指定CXF-RS端点的标签(或者甚至是这样的概念？),当我可以<jaxrs:server>完全使用标签时.

这是Camel和CXF的配置XML:

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:jaxrs="http://cxf.apache.org/jaxrs"
    xmlns:camel="http://camel.apache.org/schema/spring"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd      
        http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd
        http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd
        http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd
        http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

    <jaxrs:server id="userService" address="/users">
        <jaxrs:serviceBeans>
            <bean class="com.example.UserServiceNoop" />
        </jaxrs:serviceBeans>
        <jaxrs:providers>
            <bean class="org.codehaus.jackson.jaxrs.JacksonJaxbJsonProvider" />
        </jaxrs:providers>
    </jaxrs:server>

    <bean id="user" class="org.apache.camel.component.direct.DirectComponent" />

    <camel:camelContext id="someCamelContext">
        <camel:route id="userServiceRoute">
            <camel:from uri="cxfrs:bean:userService" />
            <camel:routingSlip>
                <camel:simple>user:${header.operationName}</camel:simple>
            </camel:routingSlip>
        </camel:route>

        <camel:route id="userServiceRetrieveUser">
            <from uri="user:retrieveUser" />
            <!-- Assume this is going to a useful Processor -->

        </camel:route>  
    </camel:camelContext>
</beans>

UserService.java:

package com.example;

/* a bunch …

我有一个使用Spark似乎相对简单的用例,但似乎无法找到一个确定的方法来做到这一点.

我有一个数据集,其中包含各种用户的时间序列数据.我要做的就是:

• 按用户标识对此数据集进行分区
• 对每个用户的时间序列数据进行排序,然后应该将其包含在各个分区中,
• 将每个分区写入单个CSV文件.最后,我希望每个用户ID最终得到1个CSV文件.

我尝试使用以下代码片段,但最终得到了令人惊讶的结果.我最终得到每个用户ID 1个csv文件,一些用户的时间序列数据最终得到排序,但很多其他用户都没有排序.

# repr(ds) = DataFrame[userId: string, timestamp: string, c1: float, c2: float, c3: float, ...]
ds = load_dataset(user_dataset_path)
ds.repartition("userId")
    .sortWithinPartitions("timestamp")
    .write
    .partitionBy("userId")
    .option("header", "true")
    .csv(output_path)

我不清楚为什么会发生这种情况,我不完全确定如何做到这一点.我也不确定这是否可能是Spark中的一个错误.

我正在使用Spark 2.0.2和Python 2.7.12.任何建议将非常感谢!