Apache Airflow Operator exporting AWS Cost Explorer data to local file or S3
Project description
Airflow AWS Cost Explorer Plugin
A plugin for Apache Airflow that allows you to export AWS Cost Explorer data to local file or S3 in Parquet, JSON, or CSV format.
System Requirements
- Airflow Versions
- 1.10.3 or newer
- fastparquet (optional, for writing Parquet files)
Deployment Instructions
-
Install the plugin
pip install airflow-aws-cost-explorer fastparquet
-
Restart the Airflow Web Server
-
Configure the AWS connection (Conn type = 'aws')
-
Optional for S3 - Configure the S3 connection (Conn type = 's3')
Operators
AWSCostExplorerToS3Operator
:param day: Date to be exported as string in YYYY-MM-DD format or date/datetime instance (default: yesterday)
:type day: str, date or datetime
:param aws_conn_id: Cost Explorer AWS connection id (default: aws_default)
:type aws_conn_id: str
:param region_name: Cost Explorer AWS Region
:type region_name: str
:param s3_conn_id: Destination S3 connection id (default: s3_default)
:type s3_conn_id: str
:param s3_bucket: Destination S3 bucket
:type s3_bucket: str
:param s3_key: Destination S3 key
:type s3_key: str
:param file_format: Destination file format (parquet, json or csv default: parquet)
:type file_format: str
:param metric: Metric (default: UnblendedCost)
:type metric: str
AWSCostExplorerToLocalFileOperator
:param day: Date to be exported as string in YYYY-MM-DD format or date/datetime instance (default: yesterday)
:type day: str, date or datetime
:param aws_conn_id: Cost Explorer AWS connection id (default: aws_default)
:type aws_conn_id: str
:param region_name: Cost Explorer AWS Region
:type region_name: str
:param destination: Destination file complete path
:type destination: str
:param file_format: Destination file format (parquet, json or csv default: parquet)
:type file_format: str
:param metric: Metric (default: UnblendedCost)
:type metric: str
Example
#!/usr/bin/env python
import airflow
from airflow import DAG
from airflow_aws_cost_explorer import AWSCostExplorerToLocalFileOperator
from datetime import timedelta
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': airflow.utils.dates.days_ago(1),
'email': ['airflow@example.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=30)
}
dag = DAG('cost_explorer',
default_args=default_args,
schedule_interval=None,
concurrency=1,
max_active_runs=1,
catchup=False
)
aws_cost_explorer_to_file = AWSCostExplorerToLocalFileOperator(
task_id='aws_cost_explorer_to_file',
day='{{ yesterday_ds }}',
destination='/tmp/{{ yesterday_ds }}.parquet',
file_format='parquet',
dag=dag)
if __name__ == "__main__":
dag.cli()
Links
- Apache Airflow - https://github.com/apache/airflow
- fastparquet - https://github.com/dask/fastparquet
- AWS Cost Explorer - https://aws.amazon.com/aws-cost-management/aws-cost-explorer/
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for airflow_aws_cost_explorer-1.0.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 89ae3d00cd124a2ccedb8f9207458aae0afbd343528a2838d502a94ba9548a39 |
|
MD5 | 4bf57d22b4e2ea6ec10f5279cc42ee6b |
|
BLAKE2b-256 | 4b5119cff6b1962f15b6cb8fad4fd50245c187a50671cd65955c181324e55e0f |
Close
Hashes for airflow_aws_cost_explorer-1.0.2-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8e9890b84a70e57b3dcde60c85c5624072370c8e5be869bbd6322ca47970dd03 |
|
MD5 | 93a9cd1d6bfdfc1e214116568e5047fa |
|
BLAKE2b-256 | 8cc4cf7ca8b15450d3b1f322d2a86646fb936862fccb6cb499b9030f59b9a6b2 |