import-a 0.0.1

No project description provided

important

🎁 Import-ANT 🐜 The folder of python functions and classes we can import

📦 Installation

Very simple version

pip install import-ant

With other distributions

pip install import-ant[redis]

or

pip install import-ant[kafka,redis]

pip install import-ant[kafka,snowflake]

or just get greedy and install everything, with a specified version 🚀🏎💣🔪🔫🔨🧨🧱🧲🧪🧬🧯🧰

pip install import-ant[all]==0.0.1

🧱 Databricks

Within Databricks notebooks, we can do:

import sys
sys.path.append("/Workspace/Repos/[e-mail]/important/src")

🔌 Connectors

❄️ Snowflake

from important.snowflake import SnowFlakeDatabricks
sf = SnowFlakeDatabricks.from_config()

# read data into a pandas dataframe
df = sf("SELECT * FROM some_table")

🍄 Redis

from important.redis import Redis, RedisAsync, RedisController

Vanilla Redis

# connect to redis
redis_client = Redis(host="localhost", db=0)

control = RedisController.from_task(redis_client, task="channel_pop")

# save data by key
control[dict(channel_id=137, user_id=424242)] = "Some string data"

Async Redis

redis_client = RedisAsync(host="localhost", db=0)

control = RedisControllerAsync.from_task(
    redis_client, task="channel_pop")

# save data by key, sadly the await expression doesn't support the [] syntax
await control.set(dict(channel_id=137, user_id=424242), "Some string data")

# get data by key
await control[dict(channel_id=137, user_id=424242)]