小编Nat*_*ski的帖子

Matplotlib日志刻度刻度标签编号格式

matplotlib为轴指定对数刻度时,标记该轴的默认方法是使用10到一个幂的数字,例如.10 ^ 6.是否有一种简单的方法可以将所有这些标签更改为完整的数字表示?例如.1,10,100等

请注意,我不知道功率范围是什么,并且想要支持任意范围(包括负数).

python graphing numpy matplotlib

40
推荐指数
4
解决办法
4万
查看次数

检查值是否在元组中的值对之间?

是否有一种有效的方法(很好的语法)来检查值是否在元组中包含的两个值之间?

我能想到的最好的事情是:

t = (1, 2)
val = 1.5
if t[0] <= val <= t[1]:
    # do something
Run Code Online (Sandbox Code Playgroud)

是否有更好的方法来编写条件?

python conditional tuples

9
推荐指数
1
解决办法
4338
查看次数

来自 YouTube 分析 API 的数据有多新鲜?

根据Youtube Analytics API 的延迟,来自 YouTube 分析 API 的数据应该每天更新。我正在尝试使用https://www.googleapis.com/youtube/analytics/v1/reports端点为视频提取时间数据。为此,我发送如下参数:

{ 'dimensions': 'day', 'end-date': '2015-06-02', 'filters': 'video==MY_VIDEO_ID', 'ids': 'channel==MINE', 'metrics': 'views,uniques,averageViewDuration,averageViewPercentage,comments,likes,dislikes,shares,subscribersGained,subscribersLost', 'prettyPrint': 'false', 'start-date': u'2013-03-18' }

start-date将视频的上传日期设置end-date为今天,但我只能在几天前​​获取数据。例如,上面的请求2015-05-31作为数据存在的最后日期返回。end-date如果范围是独占的,我曾尝试在未来设置额外的一天。根据Youtube Analytics API 的延迟,我应该将数据提高到2015-06-01.

Analytics API 现在是否有额外的延迟一天?我的查询有问题吗?某处是否有一个规范页面,其中包含类似于此Adwords 答案的这些延迟的数字?

youtube youtube-api youtube-analytics-api

7
推荐指数
0
解决办法
1508
查看次数

芹菜任务没有被处理

我试图过程中使用芹菜某些任务,而我并没有太多的运气.我运行celeryd和celerybeat作为后台.我有一个tasks.py文件看起来像这样一个简单的应用程序和任务定义:

from celery import Celery

app = Celery('tasks', broker='amqp://user:pass@hostname:5672/vhostname')

@app.task
def process_file(f):
    # do some stuff
    # and log results
Run Code Online (Sandbox Code Playgroud)

此文件是从process.py我用来监视文件更改的另一个文件中引用的,如下所示:

from tasks import process_file

file_name = '/file/to/process'
result = process_file.delay(file_name)
result.get()
Run Code Online (Sandbox Code Playgroud)

有了这样的小码,芹菜是无法看到任务和处理它们.我可以在Python解释器执行类似的代码和芹菜对其进行处理:

py >>> from tasks import process_file
py >>> process_file.delay('/file/to/process')
<AsyncResult: 8af23a4e-3f26-469c-8eee-e646b9d28c7b>
Run Code Online (Sandbox Code Playgroud)

当我运行从解释的任务然而,beat.log并且worker1.log不显示已收到任务的任何指示,但使用logging我可以证实在执行任务的代码.也有在没有明显的错误.log文件.什么可能导致这个问题的想法?

/etc/default/celerybeat看起来像:

CELERY_BIN="/usr/local/bin/celery"
CELERYBEAT_CHDIR="/opt/dirwithpyfiles"
CELERYBEAT_OPTS="--schedule=/var/run/celery/celerybeat-schedule"
Run Code Online (Sandbox Code Playgroud)

而且/etc/default/celeryd:

CELERYD_NODES="worker1"
CELERY_BIN="/usr/local/bin/celery"
CELERYD_CHDIR="/opt/dirwithpyfiles"
CELERYD_OPTS="--time-limit=300 --concurrency=8"
CELERYD_USER="celery"
CELERYD_GROUP="celery"
CELERYD_LOG_FILE="/var/log/celery/%N.log"
CELERYD_PID_FILE="/var/run/celery/%N.pid"
CELERY_CREATE_DIRS=1
Run Code Online (Sandbox Code Playgroud)

python task rabbitmq celery broker

6
推荐指数
1
解决办法
5214
查看次数

禁用所有子记录器

所以我有一个正在运行的 python 脚本,它logging与一个简单的顶级记录器一起使用:

logging.basicConfig(level=logging.DEBUG)
Run Code Online (Sandbox Code Playgroud)

然后该脚本导入了一堆也使用的其他东西,logging结果我得到了大量的输出,因为这些其他脚本也记录在该DEBUG级别。我希望只能logging从我的顶级记录器中获取输出,而不能从模块中的任何子记录器中获取输出。

有没有一种方法可以禁用所有子记录器而无需手动命名和配置每个记录器?

python logging python-2.7

5
推荐指数
1
解决办法
380
查看次数

为什么我的 RxJava Flowable 在使用 observeOn 时不尊重背压?

我正在尝试创建一个Flowable发出关于背压的事件以避免内存问题,同时并行运行每个转换阶段以提高效率。我创建了一个简单的测试程序来推理我的程序不同步骤的行为,以及何时发出事件与等待不同阶段。

我的程序如下:

public static void main(String[] args) throws ExecutionException, InterruptedException {
  Stream<Integer> ints = IntStream.range(0, 1000).boxed().collect(Collectors.toList())
      .stream().map(i -> {
        System.out.println("emitting:" + i);
        return i;
      });

  Flowable<Integer> flowable = Flowable.fromIterable(() -> ints.iterator());
  System.out.println(String.format("Buffer size: %d", flowable.bufferSize()));

  Long count = flowable.onBackpressureBuffer(10)
      .buffer(10)
      .flatMap(buf -> {
        System.out.println("Sleeping 500 for batch");
        Thread.sleep(500);
        System.out.println("Got batch of events");
        return Flowable.fromIterable(buf);
      }, 1)
      .map(x -> x + 1)
      .doOnNext(i -> {
        System.out.println(String.format("Sleeping : %d", i));
        Thread.sleep(100);
        System.out.println(i);
      })
      .count()
      .blockingGet();

  System.out.println("count: " + count);
} …
Run Code Online (Sandbox Code Playgroud)

java multithreading rx-java reactivex

5
推荐指数
1
解决办法
913
查看次数

缓冲区加载/文件打开时vim自动命令?

我正在尝试在vim中打开文件(缓冲区?)时执行自动命令,该文件将通过执行显示缩进指南<Leader>ig.我正在使用vundle插件nathanaelkane/vim-indent-guides

我目前正在尝试autocmd BufWinEnter <Leader> ig,但这似乎没有奏效.我也试过了<Leader>ig.

为了使这项工作,我需要改变什么?

vim autocmd vim-plugin

2
推荐指数
1
解决办法
3709
查看次数

为什么两个 Java 进程可以绑定到 macOS 中的同一个套接字?

我有一些生成套接字绑定的 Java 代码。很难提供一个最小的示例,因为这是 Web 框架的一部分,但它在某些时候有效地执行了此检查。

  private static boolean portInUse(int port) {
    // try to bind to this port, if it succeeds the port is not in use
    try (ServerSocket socket = new ServerSocket(port)) {
      socket.setReuseAddress(true);
      return false;
    } catch (IOException e) {
      return true;
    }
  }
Run Code Online (Sandbox Code Playgroud)

我可以看到,如果我使用同一端口运行两个不同的 Java 进程,它们都会落入第一个条件并返回false,因此两者都能够绑定到同一端口。我已经阅读了一些相关的套接字问题和解释,例如 this,但它们似乎听起来像是我指定的选项不可能实现这一点。看看setReuseAddress它的实现似乎只SO_REUSEADDR在套接字上设置。

我可以看到一个进程最终有一个套接字,就像ServerSocket[addr=0.0.0.0/0.0.0.0,localport=56674]在调试器中一样。如果我运行类似的命令,sudo lsof -n -i | grep -e LISTEN -e ESTABLISHED | grep 56674我可以看到两个进程绑定到同一端口:

java      68863    natdempk 1256u  IPv4 …
Run Code Online (Sandbox Code Playgroud)

java sockets macos networking serversocket

2
推荐指数
1
解决办法
181
查看次数