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_google_sheet

source

/**
 * @param array{type: string, project_id: string, private_key_id: string, private_key: string, client_email: string, client_id: string, auth_uri: string, token_uri: string, auth_provider_x509_cert_url: string, client_x509_cert_url: string}|Sheets $auth_config
 * @param string $spreadsheet_id
 * @param string $sheet_name
 * @param bool $with_header - @deprecated use withHeader method instead
 * @param int $rows_per_page - how many rows per page to fetch from Google Sheets API - @deprecated use withRowsPerPage method instead
 * @param array{dateTimeRenderOption?: string, majorDimension?: string, valueRenderOption?: string} $options - @deprecated use withOptions method instead
 */
from_google_sheet(Sheets|array $auth_config, string $spreadsheet_id, string $sheet_name, bool $with_header, int $rows_per_page, array $options) : Extractor

from_google_sheet_columns

source

/**
 * @param array{type: string, project_id: string, private_key_id: string, private_key: string, client_email: string, client_id: string, auth_uri: string, token_uri: string, auth_provider_x509_cert_url: string, client_x509_cert_url: string}|Sheets $auth_config
 * @param string $spreadsheet_id
 * @param string $sheet_name
 * @param string $start_range_column
 * @param string $end_range_column
 * @param bool $with_header - @deprecated use withHeader method instead
 * @param int $rows_per_page - how many rows per page to fetch from Google Sheets API, default 1000 - @deprecated use withRowsPerPage method instead
 * @param array{dateTimeRenderOption?: string, majorDimension?: string, valueRenderOption?: string} $options - @deprecated use withOptions method instead
 */
from_google_sheet_columns(Sheets|array $auth_config, string $spreadsheet_id, string $sheet_name, string $start_range_column, string $end_range_column, bool $with_header, int $rows_per_page, array $options) : Extractor

Contributors

Join us on GitHub