Logstash顺序线程执行流程

文章/答案/技术大牛

发布

2回答

logstash、logstash-input-jdbc

我在配置中创建了两个jdbc部分，但我希望始终先执行actionA，然后执行actionB，这对我来说很重要。我该怎么做呢？

浏览 12提问于2016-08-04得票数 0

1回答

维护数据读取顺序的logstash

logstash

我有一个logstash实例并从多个文件中读取数据。我希望保持在Elasticsearch中更新数据的顺序，因为_id字段是关键。Key = C1 , Data = hij , time=5:53 PM Key = A1 , Data = klm, time=5:50 PM 这将由logstash中的两个线程读取。

浏览 3提问于2015-01-15得票数 0

回答已采纳

1回答

关于洛什的事。热输出填充的日志通过收集订单？

linux、elasticsearch、logstash、filebeat

我正在用logstash过滤器掩蔽我的部分日志。 type: 01 number: 20290520021255J}}]{"message":"}}] ","@timestamp":"2022-02-22T03:19:56.931Z"} "msn“字段已通过我的配置成功地过滤，但正

浏览 8提问于2022-02-22得票数 0

回答已采纳

1回答

及时将多个日志从filebeat发送到logstash

elasticsearch、logstash、filebeat

我已经配置了filebeat和logstash，以便维护同步，但日志不是及时的，因为我的一些逻辑在处理它时遇到了问题。 glob模式

浏览 27提问于2019-07-23得票数 0

2回答

我的流程中有许多工作项，比如A,B,C。它以A--->B--->C顺序开始。在我的例子中，B是对3rd party web服务的调用。仅当B成功时，才应处理C。在工作项内部，我将启动另一个线程，该线程将进行重试，最后它将调用completeWrokItem()方法。但是在这种情况下，我的流程引擎线程将不必要地等待completeWrokItem()调用。但是如果我调用command，它将在另一个线程中执行，而进程线程将<

浏览 0提问于2015-02-25得票数 0

4回答

Python脚本-提高速度

python、performance

目前，脚本大约需要40分钟才能完全运行，我感兴趣的可能是其他一些加速脚本的方法，两个想法要么是线程处理，要么是多个运行实例。这就是现在的执行顺序：这似乎可能会大大加快线程处理，但我不太确定流程流程会是什么样子，因为我不熟悉线程处理。如果有人可以提供一个示例，高级流程

浏览 1提问于2013-01-28得票数 2

回答已采纳

1回答

Java MultiThreading通信，生产者-消费者取消，四个线程交互。任何干净健壮的方法都行

java、multithreading、concurrency、thread-safety、race-condition

 逻辑流程A，处理一个新批处理顺序，涉及3个线程逻辑流程B，取消批处理订单，1个线程如果步骤

浏览 1提问于2019-07-19得票数 0

2回答

unordered_map的顺序是确定性的吗？

c++、dictionary、deterministic、unordered

我想知道是否可以保证unordered_map的顺序在所有CPU、线程等之间始终是相同的。我意识到特定的顺序本身可能没有明显的模式(因此，“无序”映射)，但是如果我在另一台机器上运行我的进程，或者连续多次运行，或者在不同的线程上运行，如果散列函数和插入顺序保持不变，插入项的顺序是否总是相同的呢换句话说，如果我的代码不改变，我的流程的每一个执行都会导致映射元素的顺序相同吗？我已经运行了几个测试，每次插入后的项目顺序似

浏览 0提问于2018-02-11得票数 3

2回答

观察线程中的不同输出

c#、asp.net、.net、multithreading

我在探索线程概念，每次我尝试执行下面的代码时，我都会得到不同的输出。我首先要启动ThreadOne，但是为什么ThreadTwo要开始呢？为什么我得到不同的输出？有人能详细解释一下吗？提前谢谢。

浏览 4提问于2014-08-25得票数 0

回答已采纳

1回答

logstash

我使用Docker构建我的Logstash7.10.1映像，我用以下内容覆盖了logstash.conf： uri => "mongodb://admin:pass@localhost::PipelineAction::Create/pipeline_id:main，logstash.agent未能执行动作:exception=>"LogStash::ConfigurationError/logstash<

浏览 2提问于2021-01-19得票数 0

2回答

logstash将json输入的顺序更改为弹性搜索

elasticsearch、apache-kafka、logstash

我有一个运行的logstash进程，它正在使用来自kafka主题的数据。kafka topic中的消息已经是json格式。logstash只是在弹性搜索中推送它们。但是在这样做的同时，logstash改变了字段的顺序。有一个团队正在使用csv格式的数据，因此更改的顺序给他们带来了麻烦。可能的原因是什么？logstash在弹性中推送，然后在弹性中，它看起来像{"foo2":"bar2"，"foo1":"bar1"

浏览 3提问于2017-05-09得票数 0

1回答

尽管Logstash中有加重，但ElasticSearch中的重复条目

csv、elasticsearch、logstash

日志的最后几行：[2017-01-18T11:34:09,977][DEBUG][logstash</e

浏览 6提问于2017-01-18得票数 0

回答已采纳

1回答

GCD串行线程执行流程

ios、multithreading、grand-central-dispatch

在下面的示例函数中 dispatch_queue_t serialQueue = dispatch_queue_create("com.unique.name.queue", DISPATCH_QUEUE_SERIAL); NSLog(@"1"); NSLog(@"2"); NSLog(@"

浏览 1提问于2016-05-07得票数 0

回答已采纳

2回答

理解std::condition_variables

c++、c++11、condition-variable

当我有多个线程等待执行时，我试图理解condition_variable的流程。据我所知，所有线程都会试图获取唯一的锁，其中一个会得到它，然后继续到wait()，如果您调用notify_all，那么最多不会有一个线程等待通过。直到它释放它的锁并允许其他线程通过。cv是否与唯一的锁进行通信，并让所有线程同时通过？如果是这样的话，它是否真的是一次又一次地执行线程的顺序通过一个又一个。

浏览 1提问于2015-09-25得票数 3

回答已采纳

3回答

使用定时器和TimerTask时的Java线程执行顺序

java、multithreading、timer

逻辑流程如下：T1:在主调用线程中，睡眠5秒T5:睡眠结束但是，当我在我的SLES 10构建服务器上运行相同的代码时，日志记录显示以下执行顺序：T1:主线程休眠5秒T6:计时器取消 T7:任务执

浏览 2提问于2010-07-20得票数 0

点击加载更多