The Reddit source supports Full Refresh as well as Incremental syncs.
Full Refresh sync means every time a sync is run, Airbyte will copy all rows in the tables and columns you set up for replication into the destination in a new table. Incremental sync means only changed resources are copied from Reddit. For the first run, it will be a Full Refresh sync.
You can make a POST request from Postman to exchange your Reddit username and password for an api_key
authorized to make requests.
First make an app to get the client ID and secret for authentication:
- Go to Reddit's App Preferences Page:
- Visit
https://www.reddit.com/prefs/apps
, selectcreate another app
and input an app name. Select thescript
option and set the redirect URI ashttps://oauth.pstmn.io/v1/callback
.
- Copy Your App Credentials:
- After creating the app, you will see the Client ID (below your app name) and Client Secret (labeled as "secret").
- Client ID: Copy this value as it will be your Authorization Username in Postman.
- Client Secret: Copy this value as it will be your Authorization Password in Postman.
- Visit Postman via web or app and make a new request with following guidelines:
- Request - POST
https://www.reddit.com/api/v1/access_token
- Authorization - Basic Auth -
username: <YOUR_USERNAME>
,password: <YOUR_PASSWORD>
- Body - x-www-form-urlencoded -
grant_type: password, username: YOUR_REDDIT_USERNAME, password: YOUR_REDDIT_PASSWORD
Hit send to receive api_key
in the response under access_token
- The Reddit API has rate limiting of 100 queries per minute (QPM) per OAuth client ID. It is handled with an exponential backoff strategy, with maximum 3 retries.
- If the
api_key
expires, a new access token will need to be generated through Postman. - The Reddit API has a hard limit of fetching 1000 records per single stream call with subsequent pagination.
Input | Type | Description | Default Value |
---|---|---|---|
api_key | string | API Key. | |
query | string | Query. Specifies the query for searching in reddits and subreddits | airbyte |
include_over_18 | boolean | Include over 18 flag. Includes mature content | false |
exact | boolean | Exact. Specifies exact keyword and reduces distractions | |
limit | number | Limit. Max records per page limit | 1000 |
subreddits | array | Subreddits. Subreddits for exploration | [r/funny, r/AskReddit] |
start_date | string | Start date. |
Stream Name | Primary Key | Pagination | Supports Full Sync | Supports Incremental |
---|---|---|---|---|
self | name | No pagination | ✅ | ❌ |
search | DefaultPaginator | ✅ | ❌ | |
subreddit_search | DefaultPaginator | ✅ | ❌ | |
message_inbox | DefaultPaginator | ✅ | ❌ | |
subreddit_popular | DefaultPaginator | ✅ | ❌ | |
subreddit_explore | DefaultPaginator | ✅ | ✅ |
Expand to review
Version | Date | Pull Request | Subject |
---|---|---|---|
0.0.3 | 2024-10-29 | 47827 | Update dependencies |
0.0.2 | 2024-10-28 | 47542 | Update dependencies |
0.0.1 | 2024-08-23 | 44579 | Initial release by btkcodedev via Connector Builder |