Metadata-Version: 2.1
Name: airflow-socrata-plugin
Version: 0.0.1
Summary: An Apache Airflow plugin to upload to Socrata.
Home-page: https://github.com/xyx0826/Airflow-Socrata
Author: xyx0826
Author-email: xyx0826@hotmail.com
License: UNKNOWN
Platform: UNKNOWN
Classifier: Programming Language :: Python :: 3
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: POSIX :: Linux
Classifier: Environment :: Plugins
Description-Content-Type: text/markdown

# Airflow-Socrata
Simple hooks and operators for uploading data to Socrata.

# Features
- Upsert or reupload PostgreSQL tables to Socrata

# Install
Using pip:
```bash
pip3 install airflow-socrata-plugin
```

# Usage
Create a connection named `http_socrata` of type `http` to store Socrata credentials. *You can also pass in `conn_name` parameter in DAG definition to override.*

Create a connection named `etl_postgres` of type `postgres` to store PostgreSQL credentials. *You can also pass in `postgres_conn_name` parameter in DAG definition to override.*

By default, the plugin looks for the specified table under `public` schema. The schema can be specified with `postgres_schema` parameter.

The plugin is published as a pip package. Refer to the [example DAG](example_dag.py) for available parameters.


