bytewax-webflow 0.2.0

Webflow connectors for Bytewax

Byteflow Webflow

Webflow connectors for Bytewax.

This connector offers 1 sink:

• WebflowCollectionSink - inserts or updates a specified Webflow Collection.

Installation

This package is available via PyPi as bytewax-webflow and can be installed via your package manager of choice.

Usage

import os
import bytewax.operators as op
from bytewax.testing import TestingSource
from bytewax.dataflow import Dataflow
from bytewax_webflow import WebflowCollectionItemSink, WebflowCollectionItem

WEBFLOW_ACCESS_TOKEN = os.environ["WEBFLOW_ACCESS_TOKEN"]
WEBFLOW_COLLECTION_ID = os.environ["WEBFLOW_COLLECTION_ID"]

flow = Dataflow("webflow_example")

flow_input = op.input("input", flow, TestingSource(["Earth", "Mars"]))


def create_webflow_item(value: str) -> WebflowCollectionItem:
    return WebflowCollectionItem(
        name=f"Hello {value}",
        slug=value,
        fields={
            "planet": value,
        }
    )

transform = op.map("transform", flow_input, create_webflow_item)

op.output("output", transform, WebflowCollectionItemSink(WEBFLOW_ACCESS_TOKEN, WEBFLOW_COLLECTION_ID))

License

Licensed under the MIT License.