hongbo-miao/hongbomiao.com

View on GitHub
data-storage/delta-lake/read-delta-lake-by-amazon-athena/src/main.py

Summary

Maintainability
A
0 mins
Test Coverage
import logging

import awswrangler as wr


def main():
    df = wr.athena.read_sql_query(
        "select * from motor limit 10;",
        database="production_hm_iot_db",
    )
    logging.info(df)


if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    main()