# Pipeline to pipeline communication

**URL:** https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140
**Category:** Logstash
**Created:** [May 5, 2021, 7:31am UTC](https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140 "2021-05-05T07:31:55Z")
**Posts on this page:** 4
**Page:** 1

<div class="post-metadata">

### Author: ![bdn](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/bdn/32/136737_2.png) [@bdn](https://discuss.elastic.co/u/bdn)
#### Post date: [May 5, 2021, 7:31am UTC](https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140/1 "2021-05-05T07:31:56Z")

</div>

I have a requirement. Events will be listening on some TCP ports in Logstash. using a filter plugin I will extract the username field from the event. After that, I have to query another API server providing that username and get the output back and store it in Elastic. What are the things that I have to look to build this pipepline? It can be done through logstash?

---

<div class="post-metadata">

### Author: ![Wolfram\_Haussig](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/wolfram_haussig/32/70528_2.png) [@Wolfram\_Haussig](https://discuss.elastic.co/u/Wolfram_Haussig)
#### Post date: [May 5, 2021, 8:51am UTC](https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140/2 "2021-05-05T08:51:02Z")

</div>

Hello Bidhan,

Yes, this can be achieved using LogStash without having to use pipeline to pipeline communication. you need:

- [TCP input plugin](https://www.elastic.co/guide/en/logstash/current/plugins-inputs-tcp.html) to get the logs
- [Grok filter](https://www.elastic.co/guide/en/logstash/current/plugins-filters-grok.html) to extract the username
- [HTTP filter](https://www.elastic.co/guide/en/logstash/current/plugins-filters-http.html) to call the API server
- optionally, [Mutate filter](https://www.elastic.co/guide/en/logstash/current/plugins-filters-mutate.html) to remove uninteresting fields
- [Elasticsearch Output](https://www.elastic.co/guide/en/logstash/current/plugins-outputs-elasticsearch.html) to send the results to ElasticSearch

Best regards  
Wolfram

---

<div class="post-metadata">

### Author: ![bdn](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/bdn/32/136737_2.png) [@bdn](https://discuss.elastic.co/u/bdn)
#### Post date: [May 5, 2021, 9:12am UTC](https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140/3 "2021-05-05T09:12:21Z")

</div>

Thank you for your reply. I thought the HTTP plugin is an output plugin. I was mistaken. 😃 Thanks for your suggestion.

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)
#### Post date: [June 2, 2021, 9:12am UTC](https://discuss.elastic.co/t/pipeline-to-pipeline-communication/272140/4 "2021-06-02T09:12:44Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.
