Eisvidas Arrayly

I hereby claim:

To claim this, I am signing this object:

	from datetime import datetime
	from elasticsearch import Elasticsearch
	import json
	import os
	import logging
	import time
	import asyncio
	import aiofiles
	from concurrent.futures import ThreadPoolExecutor

	#!/bin/bash
	# =============================================================================
	# Author: Eisvidas Jonkus
	# Email: [email protected]
	# Created: 06.10.2023
	# Modified: 22.11.2023
	# Version: 1.8
	# License: This script is licensed for use
	# Description: Installs Elasticsearch agent and APM and restarts tomcat
	# =============================================================================

	import pika

	private_ip = "10.0.2.248"

	# Construct the RabbitMQ connection string
	rabbitmq_connection_string = f"amqp://sdkuser:sdkuserfa77e8704f07404ab4b923b1fdd23608@{private_ip}:5672/sdk"

	# Establish a connection to RabbitMQ
	connection = pika.BlockingConnection(pika.URLParameters(rabbitmq_connection_string))
	channel = connection.channel()