UNIFIED DATA PROCESSING FRAMEWORK

composer require flow-php/etl ^0.10.0

Changelog

Extracts

Read from various data sources.

Transforms

Shape and optimize for your needs.

Loads

Store and secure in one of many available data sinks.

Modules

DSL Functions

DSL stands for Domain Specific Language. In the case of Flow, the DSL is used to define simple functions that can be used to transform data. Most of those functions are initializing a new instance of a class under the hood since Flow is fully object-oriented. Please look at the examples below to get a better understanding of how to use the DSL functions.

EXTRACTOR

from_json

source

/**
 * @param Path|string $path - string is internally turned into stream
 * @param ?string $pointer - if you want to iterate only results of a subtree, use a pointer, read more at https://github.com/halaxa/json-machine#parsing-a-subtree - @deprecate use withPointer method instead
 * @param ?Schema $schema - enforce schema on the extracted data - @deprecate use withSchema method instead
 */
from_json(Path|string $path, ?string $pointer, ?Schema $schema) : JsonExtractor

LOADER

to_json

source

/**
 * @param Path|string $path
 * @param int $flags - PHP JSON Flags - @deprecate use withFlags method instead
 * @param string $date_time_format - format for DateTimeInterface::format() - @deprecate use withDateTimeFormat method instead
 * @param bool $put_rows_in_new_lines - if you want to put each row in a new line - @deprecate use withRowsInNewLines method instead
 *
 * @return JsonLoader
 */
to_json(Path|string $path, int $flags, string $date_time_format, bool $put_rows_in_new_lines) : JsonLoader

Contributors

Join us on GitHub