About this integration
Use your Twilio Account SID
and Auth Token
to build Twilio tasks right into your Dagster pipeline.
Installation
pip install dagster-twilio
Example
# Read the docs on Resources to learn more: https://docs.dagster.io/deployment/resources
from dagster import op, job
from dagster_twilio import twilio_resource
import os
@op(required_resource_keys={'twilio'})
def my_op(context):
context.resources.ssh.sftp_get("/path/to/remote.csv", "path/to/local.csv")
@job(resource_defs={
'twilio': twilio_resource.configured({
'account_sid': 'my_sid',
'auth_token': os.environ['TWILIO_AUTH_TOKEN'],
})
})
def my_job():
my_op()
About Twilio
Twilio provides communication APIs for phone calls, text messages, and other communication functions.