Skip to content

Instantly share code, notes, and snippets.

View demichevaa's full-sized avatar

Alexander Demichev demichevaa

View GitHub Profile
from pyspark.sql import SparkSession
from sshtunnel import SSHTunnelForwarder
spark = SparkSession.builder.getOrCreate()
# ssh setup
tunnel = SSHTunnelForwarder(
('example-remote-host', 22),
ssh_username='example-user',
ssh_password='example-pswd',
currency value date
EUR 38 2021-01-01
EUR 65 2021-01-01
EUR 74 2021-01-01
EUR 42 2021-01-01
EUR 23 2021-01-01
EUR 48 2021-01-01
EUR 86 2021-01-01
EUR 74 2021-01-01
EUR 24 2021-01-01