Import into a node Importing (or ingesting ) data can be done by running a
pipeline that ends with the
import
sink operator. When managing a pipeline
through the app or the API, all pipeline operators run within the node. When
using the CLI, at least the import
operator runs within the node.
eyJ2ZXJzaW9uIjoiMSIsImVuY29kaW5nIjoiYnN0cmluZyIsImNvbXByZXNzZWQiOnRydWUsImVuY29kZWQiOiJ4nO1d6VbbSFx1MDAxNv6fp+DQP/pPW1370v9cZsZAXGJgMFx1MDAxMGCmXHUwMDBmR5GEUbzIyDJbd1x1MDAxZWWeYd5pnmRuXHUwMDE5sFx1MDAxNluWzVx1MDAxMjtpm1x1MDAxY1x1MDAxNql0q1T3fnetqvz1YWVlNbrveqt/rKx6d47d8t3Qvl39zVxcv/HCnlx1MDAxZnTgXHUwMDE2XHUwMDE5/N1cdTAwMGL6oTNoeVx1MDAxNUXd3lx1MDAxZr//bne7VvyU5Vx1MDAwNO3HJ72W1/Y6UVx1MDAwZtr+XHUwMDBi/l5Z+WvwPdFX6DmR3Wm0vMFcdTAwMDODW3F3mKDs1b2gM+hcdTAwMWFLQSnhSuthXHUwMDBiv1eB/lwiz4Xbl3ar58V3zKXVr+VrUVf7bd3dWev6XCK4u0O7Ku720m+16tF96/HFbOeqXHUwMDFmJlx1MDAwNtWLwqDpffbd6Mr0nrk+fK5cdTAwMTfAXHUwMDE0xE+FQb9x1fF6vdQzQdd2/OjeXFxD8Vx1MDAwYj7Owlx1MDAxZivxlTvTXHUwMDAyq/jC4JHE34+dr1x1MDAwN60gNJ3/comUg1Dc/Vx1MDAxN9tpNmBcZlx1MDAxZHfYJlxu7U6va4fAlbjd7dNr0cRwrjy/cVx1MDAxNVx1MDAxOZ6LRIfeYHaxJphhRTBcdTAwMWTeMd10t91cdTAwMDGn/4znNLTb3rZ5pNNvtZLT0nGfpiV144u5sZFcdTAwMTWapOCkhCfy7uK3SHB667xUbX89OzugXHUwMDA39lZzJ9hccln5enXY7ttv48k+PlxcieqdLnedi+Co4lSOeGQ39ki6l+f+7TBcZm5cdTAwMTN0n36L37/fde1HgcRcdTAwMTJcdTAwMTFBMVx1MDAxNZzpeNZafqeZnYNW4DRjXHUwMDE5/pBcdTAwMTjwXGJ4Uu+fxFxyVrm40Vx1MDAxYSHgXHUwMDFjm1x1MDAxZTfjZ3PRcUORsJRAiFCmXHUwMDE1p5xkUMTfXHJFTFhEas1cdTAwMDFNRFx1MDAxMy30XHUwMDE4TPFcdTAwMTFIIc0wXHUwMDEyOsGXd4LUW0pnPKqgXHUwMDEz1f1cdTAwMDfDh4TONlerdttv3af4OFx1MDAxMFuYxb3ATUiKuVpu+VxyI8CrXHUwMDBljNZcdTAwMGJTslx1MDAxZPlgX4ZccqKgXHUwMDFi33WgXHUwMDFm2+944fY0ij5cYv2G37FbR2OHXHUwMDAxL+1tPfNcdFtcdE59sXueuTtcdTAwMTCfibicbNRcdTAwMTDNXlx1MDAxZIJTIUFBcGQ8V0XgvFH3XHUwMDE33kZcdTAwMTmVXHUwMDFmTsLjXHUwMDFh2mrIh1x1MDAwNlp0cDKxgDZNcFxyZk2zmOFcdTAwMGJl0z7u99UpxVx1MDAxNXVWvWxcdTAwMWRcbvtj+1aLmWxcdTAwMGbCTGmSXHUwMDE09HexPYjkijcxxlx1MDAwNyxcdTAwMTCfWrzHv/WCizdXP5bp0UJpyVx1MDAwNJZzND0zXHUwMDBi52Kanlx1MDAwMnX8/qZn0Go8LCc4hVx1MDAwMlPFXHUwMDE4XHUwMDEz0zuFTrluO5fXXHUwMDAwncb5XXBcdTAwMTT2/a16sPDARMTSglGkpKZUXHSRXHUwMDAyJlxioYUkw4RcYqlBV9F8nKLBZ1wiTn/xtOd4l6NcdTAwMTglhFmSXHUwMDBiRFx1MDAxOFx1MDAxMoRcdTAwMGKB2ChIwYG3XHUwMDA0JYwpQVx1MDAwNVOYxNB8XHUwMDAyraCcUo31+FxibGhcdTAwMTZWQ6VsNzovhSW/r6P7k/ut8peNhH1Z7ftHQYutiZvKRumcVcJcdTAwMGWttHmywfZabe0murg/27tmtv9p7+tDWDt5NjwzKYfY3j2LK3m68i2eySl1XHUwMDA2opJoRoiUSfhMqzN6kVx1MDAxZEZrfsf1O43sI17HzbnTsnvRetBu+1x1MDAxMVxmo1x1MDAxNvidKNtiQLdsosIrz1x1MDAxZZlcdTAwMGKgnHuva8ileVx1MDAxN/+2XHUwMDEyy/Hgj+Hvf/42tnVcdFtgebBcdTAwMTLgz3AsNFck+TxjXHUwMDE2J0pILEG0OMJF5JAlITJcdTAwMDDMXGJCXGLlXFyKJDWlLVx1MDAwMbZDYKGIXHUwMDEwWtNicogyJlx1MDAxMVBkgsFcYklqdFqD8dRUUDBKXHUwMDFjXHUwMDEzVEhcdTAwMGZjiyPGNJGKcKlTxDBiXHUwMDAzi8hcYteAbVJIjMPUMUUkkWDARcJWP1JTXHUwMDE2XHUwMDAyMMKgMDZcdTAwMDBUxWNTRuNwXHUwMDAwPIR2oFVomp62sOSIY07BXG5rIVxu6SlqMVx0sFdcZitFpWRpetKieODFSm76K6RHsLQk4zBcYqwxXHUwMDA1XHUwMDAzINL0iKVcdTAwMTRcdTAwMDQsXGI0XCK8NCt8X1x1MDAxMFx1MDAxMItLXHUwMDA1UscgklFcXPBcZmsxxDdcdTAwMWFpXHUwMDAxk4c5KSZHwVxmSnhRXHUwMDA1WptpnKKGLHhVTpjiIJnFYmzGJlx0zFxuXHUwMDAywVx1MDAwMvam31VcdTAwMDImXGImwFYkXHUwMDE1ZpLyYnogeFx1MDAwNIZGXHUwMDExzDSB2DlJr4QsXG5shylgwFx1MDAxMk2BXHUwMDFkhVx1MDAwNIF9Jlx1MDAwNFx1MDAwNFx1MDAwYlx1MDAwMbxAPNb6XHUwMDAzgmA2XHUwMDAwZIhLXGJVKOGscPZcdTAwMDCUlpZCXHUwMDAznFx1MDAwMGcgMSlyRlTAJ8Am62BEqZhcdTAwMWNIP7BVXHUwMDFimFx1MDAxYnIp1pa0XHUwMDA1Uk61XHUwMDA0xHGMRSE1bkwxqG+YIymN+KWoQU/AXHUwMDA1rcEvXHUwMDA1UHPGishpXHUwMDBiTKqUMH1YXHUwMDAwKlSKtyVqKaqBXHJUXHUwMDEzQIaQrFBcdTAwMGZcdTAwMDD7QPdIXHQ6XHUwMDE05lx1MDAxYZSUSGs9uI84XHUwMDA1XHLGzftcIsSkKFx1MDAwNEeeXHUwMDEy/5D8mefYea2W3+3l+HYqkTZcdTAwMWHJKcA0QiiAp88pbGwz2uCVYHNcdTAwMTNdXGLWP1E3XHUwMDFl/7L4vlx1MDAxZHAk+ck4d3BcdTAwMWJTXG5cYuKcYMxe59spobxkXHUwMDFjmvTtQCNcdTAwMTBQINAhhDVj4i/QaExcdTAwMWHBZ4BxXHJoXHUwMDFmde2kiVx1MDAxZH8o1+7lcVx1MDAxZvxLhG2vTErkRj/J0CZcdTAwMDNcdTAwMTCFQIGD2po+9jk/Xtfu8Wb48ZDVXHUwMDAzfeI6LffUWXh8yDQgXGJcdTAwMDFAiIG65mBzuH5cdTAwMTUgXHUwMDFjz2WuPVxuXGL5aFx1MDAwNU1ywbiQiI9cdTAwMDKCcqPrpYSoXGY8SI3GJCiMu0iN5Vx1MDAxYouI7yWojGExg6D+U4JccvAguVx1MDAwModUXHUwMDE4hVx1MDAwNoo14+Jm7lx1MDAxNnpp1Fx1MDAwMlx1MDAwNS0xXHUwMDE1UimEIDrxSjjlaYzKy1x1MDAxNK5cdTAwMDZYZ1xmXlwihaibcjaZXlx1MDAxMblcXJlcdTAwMWX3vsUhQnZ0YqbZf5VPkasuIXDM9SfAXHUwMDEzgrenaHp/4tTZrXdqdLvB7bo6XHRcdTAwMTRcdTAwMGWqN+6i60thXCJBiFaY1Fx1MDAxMjTAXHUwMDE47Ukh2EVgqjWCeIdmXHUwMDA2XHUwMDE2q0ZcZj6xQ95EfY5xJ0B6wdtcdTAwMDDfXHUwMDE2vHhcZmFkQo0/Z3dNXFxHtJ5nYXGpPPOUp4AwgklcdTAwMDbBPzJRMckqXHUwMDEzKkzMwsGlZKg4JC1BRFxu3KZCmfja5D1Uklx1MDAxZWWWNjewXHTQOFx1MDAwNEmF+Vx1MDAwMaEsRUApamrCf4QnUStcdTAwMWNcdTAwMWRcdTAwMTDjXG7MOEFAUoKvnI2XiVx1MDAxMqY6RFx1MDAxZVx1MDAxYlx1MDAxNcbL76T7OM9eftZ9XHUwMDEwqVJq4sGpVd+a37t2bvb6l0c7dL90VKpcdTAwMWPiXHUwMDEzueiqz4RSoPaYRJhcdTAwMDGjREzlWfVBSG5SXHUwMDFiILlEUZlcdTAwMTnYXCJ5jvAqkjAy11VcdTAwMTVL5bd09caP7ju6ennleirztZ3i0qj9XHUwMDE430Xa7uRjXHUwMDFmhK95Xv9cdTAwMWOV6Z6/rtqqf7To2k5IYlGsmFJcdTAwMTRcdTAwMGKm4mrcQNlRZGlsLFx1MDAxNtgsjlx1MDAxMqX8l7h5eSVBXHUwMDA2nXCJKCZjtFx1MDAxY6ZcdTAwMTb4mcBcdTAwMGJjg41Ix6rkScuZkiWSgv6YSi5Rv8fYXHUwMDEyXFwjU39cdTAwMTFAVsdcdTAwMDBJ1/NjZ/u5nu+3u0GYXHUwMDEw8FRFv+VdpmV/6np+avzZ4n22z2z5PiFcbnH1XHUwMDFlv1xmpSg3fcVcdTAwMDQ4e3qWddB3tyV92pXXXHUwMDFiqHZ49LFcXKrfXHUwMDFmls9cdTAwMTZcdTAwMWSloF0tQpRcdTAwMTJcZlxcMEFl/LpcdTAwMDOB4MjCQIQoXHUwMDAydkTLuFx1MDAxNDOKU898vXyJXHLEv5aQWCNuqmZS4ZjPQ8iy0dVlilx1MDAwM0aNsZtcdTAwMTNGh/VylZTXl2A0XHUwMDA3k6NrbGp2eN33opUgXFypenZ05YX/7tSjILRcdTAwMWLvsfRmXCJUp1x1MDAxYcpUy28om1xi4NyoYlx1MDAwMoJBblx1MDAwN0W6xLrQwiXZXHUwMDBma+xQt8PyxZ2uiOPbXWejtvCrb7QwZk4jwTGFIFXFkjjMqFDwizhcdTAwMDS6oM7oqyCcXHUwMDFiVqgxq0HHwJVJXHUwMDAxI0GJ0GdcdTAwMGWrsblJXGIs44aR1iTVnMzmOLPC5mLG9ioznHRcdTAwMTmyMOGd7m5sTDTTXHUwMDBivllcIoTi/IXqXHUwMDFjKTAmWk1cdTAwMWZcdTAwMWKEzrmzU6NXqoyj/sZDv7pxcH646CpcdTAwMGIj9sPoLIZcdTAwMThEXHUwMDAxXHUwMDEwqC5V1lJlXHUwMDE1tP9ZVVx1MDAxNk+sYc+oLMohNlCJJWTFW2uaa5vVsGnf9M/X6uy28ul2e6e26Fx1MDAxYUspXGaRkFknJphKrKpcdTAwMWHqK1Blg3xcdTAwMTXnKFHTmoeLxeFLgdpcXOqrxdNXS/1jvs+aplx1MDAxMTrfY1x1MDAwMmeJaj3LMqOa0/zEXYG9aPus6mu2s7ntrC26/sGYMuCm4lx1MDAxNGNEqcgoIEwt4Fx1MDAxM2PqidUqM7BErlx1MDAxNFx1MDAwMTzxK/b9UUsyqs1KO2Wy2OOW4o2L+5Q2S1xc51x1MDAxYfdJwlx1MDAxM4Hne6dpjtZr3ztcdTAwMWST6nK6XU+T0y55gOSJaVx1MDAxONnzZLxloWdYx/KxL3Cjea/cg/OTVuWq0e19XGZP3lx1MDAxOJBuYEzDm1wiklxiZWlcbqYuXdpgg1x1MDAxNdiCsvz67atzpYRYmFx1MDAxMjW+rqGtkaWvzOw0YPPdXHUwMDA0T6hcdTAwMTDotTtcdTAwMTHz4Ddaufjff/67XHUwMDEyeZ1cdTAwMDc/LHXeZ1PiRCjmdj9VNYO/XGaVNHd1XHUwMDE5gVx1MDAxOFZLNUMq9Kh+7IfYrX5cdO+rJ3ducH61Ke5cdTAwMTdcdTAwMWWU4Kmk8lxuaTM5aT/8azFJMLeUmlx1MDAwMZPKLKDAP2oq9JWYXFz51bKslb9XXHUwMDFla32/zlx1MDAwZp25XHUwMDAzeUecYplfs5BcdTAwMDS8JIZnOKmi2pRcdTAwMWKk5/bttf3rr8cuXHUwMDBi6/u1vLJjxi2d3zlcdTAwMTXMXCLgpUpcbjaJksxCKHBwLbOTjGNmXHUwMDE20fP8LSXTRNOXrvQwXHUwMDFig1eNLa5cdTAwMDfnXGJgLsaBlo1ZMI9cdTAwMDXlUs1cdTAwMTWzhFwiSl57mFxmndqN3bU7dsNzV2p+10vnh75cdTAwMGZU8/ufrq5IXlx1MDAwNNFkPTdcdTAwMDNRXHUwMDAx8TCXaIaFXHUwMDAxXt/tNbqkeXJxqjZcdTAwMWJNXHUwMDFl4ev6xWIjXHUwMDE0PExp1o1cIm42KPNMfv47IVx1MDAxNHGLMqqUpFx1MDAwMFaEXHUwMDEzq1YmYVx1MDAxNJQnkiRcdTAwMTl/zFx1MDAwMaOEKvSiXHUwMDFk9C/C6Pqn7bnhc3zfb4HNx1PgxtlPkZ9cdTAwMGXSXG6BT5U8Qa9cYp23lWqdRNWdr7V1ue01z07PL3cqi41O8GstsJ1cXFx1MDAxYVx1MDAxN1x1MDAxN/GMl0u4spTUZiaIXHRP1YRAdIrFdXnwXHUwMDFjk42m2kJgnkD8XHTTXHUwMDAwXFw9sqRcdTAwMGVzXG7WU2oxz2pcdTAwMWFcdTAwMDNcdTAwMWaLvGi9zj8pOz3KzPjxXHUwMDBmyZ8vODKHTsjnXHUwMDEy8FxmMaLT71x1MDAwNYiO2zvH4ry9eXFzeVx1MDAxM9ZcdTAwMGY7vE4/L3w+15ya8JOcmUPMQVx1MDAxNohqNt7kXHUwMDBlxWb1MNj31r/UXHUwMDBlfbbRqu1cdTAwMWWfsCYubyU3TpONflx1MDAxYtXkabVWcs6inrx26Gk72aD1cLK7W+qfS0y8+53jh/0rdbA/90NzXHUwMDA2XHUwMDBidTVTiUzgUqk8f5aH5lxm7y1cdTAwMGbNmUhveWjO82d5aE4hueWhOan7i3RojsgtXHUwMDBlglwihWGqXHUwMDE5ojN/R7mdXHUwMDAz1Dhgn9mD7H5y3LXc7OZcIjl36YN4f6RTclx1MDAxNGhsynI2VCymL/fySJBcdTAwMDI33uzo3vytzyz/iFBcdTAwMDShjlx1MDAwMF9g+njHPfSubznlR5dn5cOtdflJeWtcdTAwMGK/SVx1MDAwMZt8e/Lch8x+wOy5XHUwMDBmuVx1MDAwMJn3sVx1MDAwZlx1MDAxMrxcdTAwMWQws2Suy+tcdTAwMThYleVcdTAwMDGdo62Xxz5cZof+nY99yCukMJS/UlxicDjg1PS1zq2L+7BLg8+sXHUwMDFheHtcdTAwMWOVXHUwMDBlXHUwMDFhrZvOwqs+cG1n2Fx0PWGvw1x1MDAxY7dCa02M5zZPrTezsY5Htdxcbl28XHUwMDE1OiF4I0DV2ERcdTAwMWVsere9Uy7t+i2yu3/Svb9cdTAwMGLOzivXW92FP+pcdTAwMTKbykliM3S66DmyXHUwMDE3Olx1MDAxZqfz2VxuzcBMXHSzfmSOXHUwMDE4fXlcdTAwMTZ0uVx1MDAxNXrKrdC5ZVGayL9nj1x1MDAxY1x1MDAxMUpcdTAwMTIu6fRcdTAwMDB2Tlx1MDAxYqXD5mn1QFx1MDAxY55FXHUwMDFk4mxX932cXHUwMDAz4Fx1MDAwNamKQoD9vOHhsSxcdTAwMWF7yM9lUcYg0pKCS5msXHUwMDEwz78qqlx1MDAwNslvPteDOF9uXn/yoOJtq6K58Fx1MDAwNXzmL99FZlx1MDAxN1x1MDAwZUIz/EdcIpP/u71FtcCYSFOE0CZHwFx1MDAwNeVcdTAwMTlfOWn1Zt/XkutcdTAwMWNjSSyIQ7hSXHUwMDAwXHUwMDA1Zuz7KIpH7K1kJvVcZiN9PWbfulx1MDAxNml2uvBcdTAwMTctXHUwMDEx/MmhnM/ozONpKH94XCK4ane79Vxi5nrIs9VcdTAwMWLfu11cdTAwMWJnXHUwMDFmXHUwMDA2XHUwMDFmk81cdTAwMWOw0ODNXHUwMDFisPrbh2//XHUwMDA326t39SJ9Node Node import Parquet or Feather Storage TCP ❯ tenzir-node ❯ tenzir '... | import' Managed Pipeline CLI Pipeline import Parquet or Feather Storage
Consider this example that takes a Zeek conn.log from our M57 dataset:
load_file "Zeek/conn.log"
read_zeek_tsv
select id . orig_h, id . resp_h, orig_bytes, resp_bytes
where orig_bytes > 1 Mi
import
The import
operator requires a node execution context. To invoke the above
pipeline successfully, you need to deploy a
node first.