Pulling Data From Stripe to Databricks using the Webhook

190809 — Thu, 15 Sep 2022 10:00:36 GMT

I am doing some investigation in how to connect Databricks and Stripe. Stirpe has really good documentation and I have decided to set up a webhook in Django as per their recommendation. This function handles events as they occur in stripe:

----------------

import json

from django.http import HttpResponse

from django.views.decorators.csrf import csrf_exempt

# Using Django

@csrf_exempt

def my_webhook_view(request):

payload = request.body

event = None

try:

event = stripe.Event.construct_from(

json.loads(payload), stripe.api_key

)

except ValueError as e:

# Invalid payload

return HttpResponse(status=400)

# Handle the event

if event['type'] == 'customer.created':

customer = event['data']['object']

elif event['type'] == 'customer.deleted':

customer = event['data']['object']

elif event['type'] == 'customer.source.created':

source = event['data']['object']

elif event['type'] == 'customer.subscription.created':

subscription = event['data']['object']

elif event['type'] == 'customer.subscription.updated':

subscription = event['data']['object']

# ... handle other event types

else:

print('Unhandled event type {}'.format(event['type']))

return HttpResponse(status=200)

-------------------------

I now need to integrate some logic to make this work. I wanted to ask:

Is there an established approach for connecting stripe to databricks?
How can I set up my endpoint in databricks?

Thanks

topic Pulling Data From Stripe to Databricks using the Webhook in Data Engineering

Pulling Data From Stripe to Databricks using the Webhook