Muhammad Zubair Saleem mzubairsaleem

ELK for Asterisk CDR

Assumption:

You have 2 VM, 1 for ELK server and the other for Asterisk server
Asterisk is setup so that CDR saved in MySQL db asteriskcdrdb
From ELK VM you can query MySQL on Asterisk server
Asterisk server IP is 192.168.100.2
asteriskcdrdb access from ELK server: user: elkdbuser pass: c03br9hncmdD2$Asd
We're doing this howto step by step on ELK server VM

Populating Elasticsearch Index with Logstash

Logstash is a free and open server-side data processing pipeline that ingests data from a multitude of sources, transforms it, and then sends it to your favorite "stash."

This section describes how one can use it on UNIX to migrate data from a PostgreSQL database to elasticsearch.

The Prerequisites

Assuming you received the certificate in DER form, saved to cert.der:

openssl x509 -inform der -in cert.der -out chain.pem

Append the content of https://letsencrypt.org/certs/lets-encrypt-x1-cross-signed.pem.txt to chain.pem.

	async function searchWithScroll(indexName, pageSize, query, maxResults) {
	let scrollId;
	let results = [];
	let _query = Object.keys(query).length === 0 ? {
	query: {
	"match_all": {}
	}
	} : {
	query: query
	};

	apiVersion: cert-manager.io/v1
	kind: Issuer
	metadata:
	name: my-issuer
	spec:
	selfSigned: {}
	---
	apiVersion: cert-manager.io/v1
	kind: Certificate
	metadata:

	/**
	* Check if a given ip is in a network
	* @param string $ip IP to check in IPV4 format eg. 127.0.0.1
	* @param string $range IP/CIDR netmask eg. 127.0.0.0/24, also 127.0.0.1 is accepted and /32 assumed
	* @return boolean true if the ip is in this range / false if not.
	*/
	function ip_in_range( $ip, $range ) {
	if ( strpos( $range, '/' ) == false ) {
	$range .= '/32';
	}

	#run this in any directory add -v for verbose
	#get Pillow (fork of PIL) from pip before running --> pip install Pillow

	import os
	import sys
	from PIL import Image

	def compressMe(file, verbose=False):
	filepath = os.path.join(os.getcwd(), file)
	oldsize = os.stat(filepath).st_size

	{
	"http_method":"GET",
	"revision":"1598475252.192415",
	"results":{
	"port1":{
	"id":"port1",
	"name":"port1",
	"alias":"",
	"mac":"00:00:00:00:00:00",
	"ip":"0.0.0.0",

	/**
	* DowngradeRetryPolicy - This module is used to retry the READ / WRITE operation
	* by downgrading the value of consistency to minimum value.
	* @constructor
	*/
	function DowngradeRetryPolicy() {
	}

	// Inherit the retry policy
	util.inherits(DowngradeRetryPolicy, RetryPolicy);

	const puppeteer = require('puppeteer');
	const merge = require('merge-img');

	const pageUrl = ''; // REPLACE ME
	const pageElement = '#svgcanvas'; // REPLACE ME

	(async() => {
	const browser = await puppeteer.launch();
	const page = await browser.newPage();
	await page.goto(pageUrl);