Fluent Bit Stream Processor: CREATE STREAM

by edsiper 6 years ago

GNU/Linux • xterm-256color • bash 3702 views

The following demo shows how to create streams of data based on results from previous queries.

The recently introduced CREATE STREAM statement allows to create a stream of data based on the results of a query from a previous stream, the example takes an input file with apache logs in JSON format and then 3 queries do stream processing:

[STREAM_TASK]
     Name  res1
     Exec  CREATE STREAM res1 AS SELECT host, code AS http_status, size FROM STREAM:apache;

[STREAM_TASK]
     Name  res2
     Exec  CREATE STREAM res2 AS SELECT * FROM STREAM:res1;

[STREAM_TASK]
     Name  res3
     Exec  CREATE STREAM res3 AS SELECT COUNT(http_status), avg(size)  FROM STREAM:res2;

Note that in the last stream task (res3) we are using the aggregation functions COUNT() and AVG().

More by edsiper

Fluent Bit + Remarkable 2 1:10

by edsiper 1 year ago

Fluent Bit + Golang plugin 1:01

by edsiper 9 years ago

Fluent Bit Stream Processor: Aggregation Functions 0:36

by edsiper 6 years ago

Fluent Bit + HTTP input PoC 1:02

by edsiper 5 years ago

See all

https://asciinema.org/a/229260

Copied!

Append ?t=30 to start the playback at 30s, ?t=3:20 to start the playback at 3m 20s.

See sharing docs for more link customization options.

Embed as image link

Use snippets below to display a preview image linking to this recording.
Ideal for places where scripts are not allowed, such as project README files.

HTML:

<a href="https://asciinema.org/a/229260" target="_blank"><img src="https://asciinema.org/a/229260.svg" /></a>

Copied!

Markdown:

[![asciicast](https://asciinema.org/a/229260.svg)](https://asciinema.org/a/229260)

Copied!

Embed the player

If you're embedding on your own page or on a site which permits script tags, you can use the full player widget:

<script src="https://asciinema.org/a/229260.js" id="asciicast-229260" async="true"></script>

Copied!

Paste the above script tag where you want the player to be displayed on your page.

See embedding docs for more player customization options.

You can download this recording in asciicast v2 format, as a .cast file.

Download

Replay in terminal

You can replay the downloaded recording in your terminal using the asciinema play command:

asciinema play 229260.cast

Copied!

If you don't have asciinema CLI installed then see installation instructions.

Use with stand-alone player on your website

Download asciinema player from the releases page (you only need .js and .css file), then use it like this:

<!DOCTYPE html>
<html>
<head>
  <link rel="stylesheet" type="text/css" href="/assets/asciinema-player.css" />
</head>
<body>
  <div id="player"></div>
  <script src="/assets/asciinema-player.min.js"></script>
  <script>
    AsciinemaPlayer.create(
      '/assets/229260.cast',
      document.getElementById('player'),
      { cols: 154, rows: 39 }
    );
  </script>
</body>
</html>

See asciinema player quick-start guide for full usage instructions.

While this site doesn't provide GIF conversion at the moment, you can still do it yourself with the help of asciinema GIF generator utility - agg.

Once you have it installed, generate a GIF with the following command:

agg https://asciinema.org/a/229260 demo.gif

Copied!

Or, if you already downloaded the recording file:

agg demo.cast demo.gif

Copied!

Check agg --help for all available options. You can change font family and size, select color theme, adjust speed and more.

See agg manual for full usage instructions.