主页 / user-324102

Василий Никпуп's questions

Martin Hope
Василий Никпуп
Asked: 2022-04-16 16:01:49 +0000 UTC
  • 0

我需要在不更改格式的情况下替换部分文本。我写了这个函数：

import docx
import os

def getText(from_filename, to_filename, old_value, new_value):
    doc = docx.Document(from_filename)
    for paragraph in doc.paragraphs:
        print(paragraph.text)
        new_text = paragraph.text.replace(old_value, new_value)
        print(new_text)
        paragraph.text = new_text
    doc.save(to_filename)

问题是粗体字体和字体苍蝇。我不知道如何做同样的事情，但保留格式。

python
Martin Hope
Василий Никпуп
Asked: 2022-03-03 22:04:16 +0000 UTC
  • 0

我有这个测试代码：

    ExecutorService pool = Executors.newFixedThreadPool(1);

    System.out.println("Starting adding new messages to pool");
    for (int i = 0; i < 60; i++) {
        pool.submit(() -> {
            try {
                TimeUnit.SECONDS.sleep(1);
                System.out.println("Done!");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
    }
    System.out.println("End of the program");
    Thread.sleep(10_000);

如果我运行它，我会看到：

Starting adding new messages to pool
End of the program
Done!
Done!
Done!
Done!
Done!
Done!
Done!
Done!
Done!

但是当缓冲区已满时，我需要让线程池生产者阻塞，然后在控制台中我会得到：

Starting adding new messages to pool
Done!
Done!
Done!
Done!
Done!
Done!
Done!
Done!
Done!

我怎样才能做到这一点？

java
Martin Hope
Василий Никпуп
Asked: 2020-06-16 22:38:35 +0000 UTC
  • 1

我有一个不应包含在字符串中的字符集。此外，连续任意字符的数量是未知的。我需要在字符串中找到每个带有特殊字符的子字符串并将其替换为空格。

这是我的选择：

string.replace("[\n\r\t\u000B\u000C]*".toRegex(), " ");

问题是它出于某种原因在每个字符后替换了一个空格。我哪里错了？

java
Martin Hope
Василий Никпуп
Asked: 2020-10-25 02:13:49 +0000 UTC
  • 0

我有一个带有此服务文件的守护进程：

[Unit]
Description=Apache Zookeeper server (Kafka)
Documentation=http://zookeeper.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
WorkingDirectory=/home/vagrant/kafka
User=vagrant
Group=vagrant
Restart=always
ExecStart=/home/vagrant/kafka/bin/zookeeper-server-start.sh /home/vagrant/kafka/config/zookeeper.properties
ExecStop=/home/vagrant/kafka/bin/zookeeper-server-stop.sh

[Install]
WantedBy=multi-user.target

重启后，我看到加载状态。如何使服务自动启动？

linux
Martin Hope
Василий Никпуп
Asked: 2020-10-17 23:34:01 +0000 UTC
  • 2

我有一个这样的文件hosts，内容如下：

 192.168.77.101 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=1 kafkaBrokerId=1
 192.168.77.102 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=2 kafkaBrokerId=2
 192.168.77.103 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=3 kafkaBrokerId=3

我不喜欢一台服务器的所有变量都必须在一行上。有没有办法让它更漂亮？在文档中，我只找到了一组服务器变量列表的描述。

ansible
Martin Hope
Василий Никпуп
Asked: 2020-10-17 04:17:58 +0000 UTC
  • 4

我有一个包含服务器列表的文件：

192.168.77.101 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=1 kafkaBrokerId=1
192.168.77.102 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=2 kafkaBrokerId=2
192.168.77.103 ansible_user=vagrant ansible_ssh_pass=vagrant zookeeperId=3 kafkaBrokerId=3

在其中一项任务中，我使用具有以下行的模板：

advertised.listeners=PLAINTEXT://{{ ansible_all_ipv4_addresses }}:9092

我的变量被转换为逗号分隔的列表。如何从初始变量中获取当前服务的 IP 地址？

linux
Martin Hope
Василий Никпуп
Asked: 2020-10-02 15:10:51 +0000 UTC
  • 1

我有一张这样的桌子：

CREATE TABLE user (
    id SERIAL PRIMARY KEY,
    name VARCHAR(50),
    last_name VARCHAR(50),
    created_at TIMESTAMP
)

我想按列分区created_at。一些消息来源说，最好按没有时间的日期进行分区，而不是timestamp按“y”。这应该会减少可能出现的问题的数量。这是否意味着我需要创建一个单独的列，例如created_at_date，并在其中写入一个没有时间的日期并将其移植？

但毕竟，为此您每次都需要指定一个额外的参数select，这会减慢请求速度+增加人为因素。不幸的是，没有足够的经验来完全理解这种解决方案的优缺点以及是否值得做。

база-данных
Martin Hope
Василий Никпуп
Asked: 2020-09-14 19:04:25 +0000 UTC
  • 1

我有 ansible 脚本来安装我需要的应用程序。这是它的样子playbook：

- hosts: all
  become: true
  vars_files:
    - vars.yml
  strategy: free

  tasks:
   - name: Update and upgrade apt packages
     become: true
     apt:
       upgrade: yes
       update_cache: yes
       cache_valid_time: 86400 #One day
   - name: hack to resolve Problem with MergeList Issue
     shell: 'find /var/lib/apt/lists -maxdepth 1 -type f -exec rm -v {} \;'
   - name: update apt cache directly (apt module not reliable)
     shell: 'apt-get clean && apt-get update'
   - name: Preliminary installation
     apt:  name=apt-transport-https force=yes
   - name: Add the Google signing key
     apt_key: url=https://packages.cloud.google.com/apt/doc/apt-key.gpg  state=present
   - name: Add the k8s APT repo
     apt_repository: repo='deb http://apt.kubernetes.io/ kubernetes-xenial main' state=present
   - name: update apt cache directly (apt module not reliable)
     shell: 'apt-get update'
   - name: Install packages
     apt: name={{ item }} state=present force=yes
     with_items: "{{ PACKAGES }}"

安装我需要的软件包时，问题出现在最后一个任务中。错误：

TASK [Install packages] *******************************************************************************************************************************
failed: [192.168.77.11] (item=[u'vim  - htop  - tmux  - docker.io', u'kubelet', u'kubeadm', u'kubectl', u'kubernetes-cni']) => {"ansible_loop_var": "item", "changed": false, "item": ["vim  - htop  - tmux  - docker.io", "kubelet", "kubeadm", "kubectl", "kubernetes-cni"], "msg": "No package matching 'vim  - htop  - tmux  - docker.io' is available"}
failed: [192.168.77.10] (item=[u'vim  - htop  - tmux  - docker.io', u'kubelet', u'kubeadm', u'kubectl', u'kubernetes-cni']) => {"ansible_loop_var": "item", "changed": false, "item": ["vim  - htop  - tmux  - docker.io", "kubelet", "kubeadm", "kubectl", "kubernetes-cni"], "msg": "No package matching 'vim  - htop  - tmux  - docker.io' is available"}
failed: [192.168.77.12] (item=[u'vim  - htop  - tmux  - docker.io', u'kubelet', u'kubeadm', u'kubectl', u'kubernetes-cni']) => {"ansible_loop_var": "it---

文件内容vars.yml：

---
PACKAGES:
  - vim  - htop  - tmux  - docker.io
  - kubelet
  - kubeadm
  - kubectl
  - kubernetes-cni

我试图ssh通过apt-get. 一切都已成功安装并正常工作。版本ansible：2.8.5。服务器Ubuntu 16.04。告诉我可能出了什么问题？

linux
Martin Hope
Василий Никпуп
Asked: 2020-09-13 22:38:23 +0000 UTC
  • 0

我有微服务和某种管理他们工作的编排器。

我试图弄清楚这是否是正确的做法：

  1. 我们通过主题 1 收到了给协调器的消息。

  2. 编排器使用主题 2 向服务 1 发送消息。

  3. 接下来，编排器通过侦听主题 3 接收来自服务 1 的已处理消息。

  4. 编排器对消息进行自己的操作，并通过主题 4 将其发送到服务 2。

  5. 通过主题 5 从服务中获取结果。

在这里，我们为来自服务的每个响应管理一个单独的队列。正常吗？创建一个带有响应的队列并通过编排器上的响应类型来了解消息的来源不是更好吗？还是为每项附加服务创建一个传输主题和第二个接受主题是否更好？

архитектура
Martin Hope
Василий Никпуп
Asked: 2020-09-09 20:26:41 +0000 UTC
  • 1

我需要运行以下命令：

    wget -q -O- 'https://download.ceph.com/keys/release.asc' | sudo apt-key add -
    echo deb https://download.ceph.com/debian-{ceph-stable-release}/ $(lsb_release -sc) main | sudo tee /etc/apt/sources.list.d/ceph.list
    sudo apt update
    sudo apt -y install ceph-deploy

ansible在不使用commandvia 命令的情况下如何做到这一点get_url（据我所知）？

linux
Martin Hope
Василий Никпуп
Asked: 2020-07-24 03:30:20 +0000 UTC
  • 1

出于教育目的，我想通过指针访问此类的第二个字段：

struct Foo {
    Foo(char a, double b): a(a), b(b) {}
    char a;
    double b;
};

我这样做：

Foo *foo = new Foo('a', 2.0);
std::cout << *((double *)((char *)foo + 1)) << std::endl;

作为回应，我得到了垃圾。我不明白为什么。我有点将指针移到一个char，我正在尝试阅读如何double. 我的错误是什么？

c++
Martin Hope
Василий Никпуп
Asked: 2020-01-21 16:35:03 +0000 UTC
  • 0

我有一个这样的列表：[1, 2, 3, 4, 2, 4, 5, 8, 2]。需要对其进行过滤，以便仅在其中多次出现的数字保留在其中。也就是说，它应该变成这样：[2, 4]. 这必须使用 Java Stream API 来完成。

想到这样的解决方案，但在我看来它不是最优化和最漂亮的：

List<Integer> input = Arrays.asList(1, 2, 3, 4, 2, 4, 5, 8, 2);
List<Integer> result = input
        .stream()
        .filter(x -> input.stream().filter(x::equals).count() > 1)
        .distinct()
        .collect(Collectors.toList());

是否有可能以某种方式隐藏流中的流并更充分地做到这一点？

java