I've done similar with the IMT and Perl years ago:
https://houstongrackles.com/~tjackson/flows_to_es/
Relevant part in Perl:
sub retrieve_flows {
my $pipe = shift;
my $primitive = shift;
my $filter = shift;
my @flows = `/usr/local/bin/pmacct -p $pipe -l -O json -c
"$primitive" -M "$filter"`;
return @flows;
}
The array there is just JSON and can be decoded afterwards.. Python should
be able to do similar with subprocess + run on 3.5+..
--
Tim
On Tue, May 3, 2022 at 2:30 PM Karl O. Pinc <k...@karlpinc.com> wrote:
> On Tue, 3 May 2022 18:19:50 +0000
> "Compton, Rich A" <rich.comp...@charter.com> wrote:
>
> > Hi, I’m trying to take the netflow records from nfacctd and process
> > them with a python script. Can someone suggest how I can do this
> > with python without having nfacctd put them into a database and then
> > have my python script read it?
>
> You could use the in-memory recording and poll and clear
> out the old data with python. I don't know how well
> that would work, depending on scale. I tend to favor
> relational databases and would lean toward using
> sqlite if you're looking for "simple". (And Postgres
> for everything else.)
>
> You are collecting tabular data, which RDBMSs excel at.
>
> Regards,
>
> Karl <k...@karlpinc.com>
> Free Software: "You don't pay back, you pay forward."
> -- Robert A. Heinlein
>
> _______________________________________________
> pmacct-discussion mailing list
> http://www.pmacct.net/#mailinglists
>
_______________________________________________
pmacct-discussion mailing list
http://www.pmacct.net/#mailinglists
