How to load Webflow data into Elasticsearch via Logstash
Elasticsearch is a popular distributed full-text search engine. By centrally storing data, you can perform ultra-fast searches, fine-tuning relevance, and powerful analytics with ease. Elasticsearch has a pipeline tool for loading data called "Logstash". You can use CData JDBC Drivers to easily import data from any data source into Elasticsearch for search and analysis.
This article explains how to use the CData JDBC Driver for Webflow to load data from Webflow into Elasticsearch via Logstash.
Using CData JDBC Driver for Webflow with Elasticsearch Logstash
- Install the CData JDBC Driver for Webflow on the machine where Logstash is running.
-
The JDBC Driver will be installed at the following path (the year part, e.g. 20XX, will vary depending on the product version you are using). You will use this path later. Place this .jar file (and the .lic file if it's a licensed version) in Logstash.
C:\Program Files\CData\CData JDBC Driver for API 20XX\lib\cdata.jdbc.api.jar
- Next, install the JDBC Input Plugin, which connects Logstash to the CData JDBC driver. The JDBC Plugin comes by default with the latest version of Logstash, but depending on the version, you may need to add it.
https://www.elastic.co/guide/en/logstash/5.4/plugins-inputs-jdbc.html - Move the CData JDBC Driver’s .jar file and .lic file to Logstash's "/logstash-core/lib/jars/".
Sending Webflow data to Elasticsearch with Logstash
Now, let's create a configuration file for Logstash to transfer Webflow data to Elasticsearch.
- Write the process to retrieve Webflow data in the logstash.conf file, which defines data processing in Logstash. The input will be JDBC, and the output will be Elasticsearch. The data loading job is set to run at 30-second intervals.
- Set the CData JDBC Driver's .jar file as the JDBC driver library, configure the class name, and set the connection properties to Webflow in the form of a JDBC URL. The JDBC URL allows detailed configuration, so please refer to the product documentation for more specifics.
- Visit the Webflow Developer Portal
- Navigate to "Apps & Integrations" in your Webflow account
- Click "Register an App" to create a new OAuth application
- Configure the application name, description, and redirect URI (CallbackURL)
- Copy the Client ID and Client Secret for use in your connection
- AuthScheme: Set this to OAuth (required)
- OAuthClientId: Client ID from your Webflow OAuth application (required)
- OAuthClientSecret: Client secret from your Webflow OAuth application (required)
- CallbackURL: Redirect URI specified in your OAuth application (required)
- InitiateOAuth: Set to GETANDREFRESH for automatic token management (recommended)
- sites:read - Read access to site information and configuration
- pages:read - Read access to site pages
- cms:read - Read access to CMS collections and items
- forms:read - Read access to forms and form submissions
- assets:read - Read access to media assets and folders
- ecommerce:read - Read access to products, orders, and inventory
- authorized_user:read - Read access to the authorized user
Authentication
Webflow uses OAuth 2.0 authentication to ensure secure access to sites, CMS collections, e-commerce data, and other resources. This authentication method allows you to securely connect to your Webflow workspace and manage resources with proper authorization.
OAuth 2.0 Setup and Configuration
Step 1: Create a Webflow OAuth Application
To set up OAuth authentication:
Required Connection Properties
Required OAuth Scopes
The Webflow API Profile requires the following OAuth scopes:
Executing data movement with Logstash
Now let's run Logstash using the created "logstash.conf" file.
logstash-7.8.0\bin\logstash -f logstash.conf
A log indicating success will appear. This means the Webflow data has been loaded into Elasticsearch.
For example, let's view the data transferred to Elasticsearch in Kibana.
GET api_table/_search
{
"query": {
"match_all": {}
}
}
We have confirmed that the data is stored in Elasticsearch.
By using the CData JDBC Driver for Webflow with Logstash, it functions as a Webflow connector, making it easy to load data into Elasticsearch. Please try the 30-day free trial.