Security News
Introducing the Socket Python SDK
The initial version of the Socket Python SDK is now on PyPI, enabling developers to more easily interact with the Socket REST API in Python projects.
io.siddhi.extension.io.file:siddhi-io-file-parent
Advanced tools
The siddhi-io-file extension is an extension to Siddhi which used to receive/publish event data from/to file. It supports both binary and text formats.
The siddhi-io-file extension supports local data storage and also following file protocols for file/folder, read/write operations
Sink
@sink(type='file', @map(type='json'), append='true', file.uri='ftp://bob:password@localhost:21/source/published.json')
define stream BarStream (symbol string, price float, volume long);
Source
@source(type='file', mode='line', file.uri='ftp://bob:password@localhost:21/source/published.json', action.after.process='keep', tailing='false', @map(type='json'))
define stream FooStream (symbol string, price float, volume long);
Sink
@sink(type='file', @map(type='json'), append='false', file.system.options='USER_DIR_IS_ROOT:false,AVOID_PERMISSION_CHECK:true', file.uri='sftp://demo:demo@localhost:22/sftp/source/published.json')
define stream BarStream (symbol string, price float, volume long);
Source
@source(type='file', mode='line', file.uri='sftp://demo:demo@localhost:22/sftp/source/published.json', action.after.process='keep', tailing='false', file.system.options='USER_DIR_IS_ROOT:false,AVOID_PERMISSION_CHECK:true', @map(type='json'))
define stream FooStream (symbol string, price float, volume long);
Sink
@sink(type='file', @map(type='json'), append='true', file.uri='smb://ubuntu:admin@212.47.250.24/sambashare/source/published.json')
define stream BarStream (symbol string, price float, volume long);
Source
@source(type='file', mode='line', file.uri='smb://ubuntu:admin@212.47.250.24/sambashare/source/published.json', action.after.process='keep', tailing='false', @map(type='json'))
define stream FooStream (symbol string, price float, volume long);
Sink
@sink(type='file', @map(type='json'), append='true', file.uri='webdav://alice:secret1234@localhost/source/published.json')
define stream BarStream (symbol string, price float, volume long);
Source
@sink(type='file', @map(type='json'), append='false', file.uri='webdav://alice:secret1234@localhost/source/published.json')
define stream BarStream (symbol string, price float, volume long);
For information on Siddhi and it's features refer Siddhi Documentation.
io.siddhi.extension.*
from here.org.wso2.extension.siddhi.*
from here.Latest API Docs is 2.0.19.
This function checks for a given file path points to a directory
This function checks whether a file or a folder exists in a given path
This function checks for a given file path points to a file
Checks for the last modified time for a given file path
This function checks for a given file's size
Archives files and folders as a zip or in tar format that are available in the given file uri.
This function performs copying file from one directory to another.
Create a file or a folder in the given location
Deletes file/files in a particular path
This function performs copying file from one directory to another.
Searches files in a given folder and lists.
This.
This function decompresses a given file
The File Sink component of the 'siddhi-io-fie' extension publishes (writes) event data that is processed within Siddhi to files.
Siddhi-io-file sink provides support to write both textual and binary data into files
The File Source component of the 'siddhi-io-fie' extension allows you to receive the input data to be processed by Siddhi via files. Both text files and binary files are supported.
The 'fileeventlistener' component of the 'siddhi-io-fie' extension allows you to get the details of files that have been created, modified or deleted during execution time.Supports listening to local folder/file paths.
There are no other dependencies needed for this extension.
For installing this extension and to add the dependent jars on various siddhi execution environments refer Siddhi documentation section on adding extensions and jars.
We encourage users to ask questions and get support via StackOverflow, make sure to add the siddhi
tag to the issue for better response.
If you find any issues related to the extension please report them on the issue tracker.
For production support and other contribution related information refer Siddhi Community documentation.
FAQs
Unknown package
We found that io.siddhi.extension.io.file:siddhi-io-file-parent demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 0 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
The initial version of the Socket Python SDK is now on PyPI, enabling developers to more easily interact with the Socket REST API in Python projects.
Security News
Floating dependency ranges in npm can introduce instability and security risks into your project by allowing unverified or incompatible versions to be installed automatically, leading to unpredictable behavior and potential conflicts.
Security News
A new Rust RFC proposes "Trusted Publishing" for Crates.io, introducing short-lived access tokens via OIDC to improve security and reduce risks associated with long-lived API tokens.