def ingest_query(
    staging_schema: str, csv_path: str, table_name: str, iam_role: str
) -> str:
    """Creates query which can be used to ingest tweets data  into tweets table with found tweets processed csv file."""

    ingest_tweets_query = f"COPY {staging_schema}.{table_name} FROM 's3://stwit-processed-bucket/{csv_path}' IAM_ROLE '{iam_role}' CSV DELIMITER ',' IGNOREHEADER 1 TIMEFORMAT 'auto';"
    return ingest_tweets_query