Data Engineer Project: An end-to-end Airflow data pipeline with BigQuery, dbt Soda, and more!

Ғылым және технология

Data Engineer Project: An end-to-end Airflow data pipeline with BigQuery, dbt Soda, and more!
🏆 BECOME A PRO WITH AIRFLOW: www.udemy.com/course/the-comp...
In the Retail data pipeline project, you will learn:
➡️ How to create a data pipeline in Airflow from scratch
➡️ How to set up your Airflow local environment with the Astro CLI
➡️ How to run data quality checks in your pipeline with Soda
➡️ How to integrate dbt and run your models with Airflow and Comos
➡️ How to isolate tasks to avoid dependency conflicts
➡️ How to upload a CSV file into Google Cloud Storage
➡️ How to ingest data into a BigQuery table using the Astro SDK
and more!
This a complete 1hr project just for you ❤️
Here are the steps with the code snippets:
robust-dinosaur-2ef.notion.si...
Fasten your seatbelt, take a deep breath, and.... let's go!

Пікірлер: 181

  • @jebgrit
    @jebgrit9 күн бұрын

    For those who got this error "UnicodeDecodeError: 'utf-8' codec can't decode byte 0xa3 in position 227179: invalid start byte" The table is created but the data is not load. at (20:59) convert the csv into utf-8 - You running again all the previous task it's work for me. Thank you Sir! Merci avec votre accent Français haha!

  • @alisherrakhimov1997
    @alisherrakhimov199710 ай бұрын

    We need more such kind of end-to-end solution based tutorials. Thanks Marc

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Will do my best 🫶

  • @sahillohiya7658

    @sahillohiya7658

    8 ай бұрын

    we need more @@MarcLamberti

  • @vinayduli8812

    @vinayduli8812

    4 ай бұрын

    @@MarcLamberti I am getting the below error when I running task test on gcs_to_raw. I could not load the data into bq because of this. But schema got loaded WARNING - Connection schemes (type: google_cloud_platform) shall not contain '_' according to RFC3986.

  • @quoridorstrategy
    @quoridorstrategyАй бұрын

    I love this format, I wish you had more like that. I think so cool useful to have end-to-end projects like that, it gives the big picture

  • @carlosrazo7532
    @carlosrazo75327 ай бұрын

    Pure gold! This is such a fascinating project end to end. Thank you Marc for such a huge video. You are a monster man, really appreciate the love and effort you put into this 🙏

  • @MarcLamberti

    @MarcLamberti

    7 ай бұрын

    Thank you ❤️❤️❤️❤️

  • @rasmusandreasson1548
    @rasmusandreasson15487 ай бұрын

    Very nice with these end to end projects! Your best video so far!!

  • @MarcLamberti

    @MarcLamberti

    7 ай бұрын

    Thank you!!

  • @jasonkhaihoang781
    @jasonkhaihoang7816 ай бұрын

    This is just awesome. I've learned a lot from watching this video. Thank you so much for creating such a great value, Marc :)

  • @MarcLamberti

    @MarcLamberti

    6 ай бұрын

    Thank you 🙏

  • @MarcLamberti
    @MarcLamberti9 ай бұрын

    BUG FIXES: ❌ "I am getting an error while launching airflow tasks test retail gcs_to_raw 2023-01-01 : UnicodeDecodeError: 'utf-8' codec can't decode byte 0xa3 in position 227179: invalid start byte" ✅ open the file with Notepad or VSCode and make sure to save it with the UTF-8 encoding then reupload the file to GCS and it will work. ❌ Dependency errors ✅ Make sure you use quay.io/astronomer/astro-runtime:8.8.0 in the Dockerfile (or airflow 2.6.1), if not use that version and restart Airflow (astro dev restart with the Astro CLI)

  • @Shrew_Bucket

    @Shrew_Bucket

    5 ай бұрын

    thx changing encoding and saving the file before uploading to bucket helped a lot

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    Please pin this comment

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    Dependency error solution didnt work.

  • @sirinebouksila9631
    @sirinebouksila9631Ай бұрын

    This is so helpful ! Thank you so much for your efforts .

  • @wiss1998
    @wiss19984 ай бұрын

    Very nice ! this is very important video,I hope we can built the same project with snowflake

  • @sprinter5901
    @sprinter59014 ай бұрын

    Hi so just like everyone else here I faced similar issue during dbt part. To solve that in requirements file use this code instead of one mentioned in video. astronomer-cosmos[dbt-bigquery] protobuf Dont put any version number ahead. Once changes are done do astro dev restart. It will take some time but it worked for me.

  • @MarcLamberti

    @MarcLamberti

    4 ай бұрын

    Thank you so much for sharing

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    ​@@MarcLamberti Thank you too for sharing this amazing project 🎉

  • @dsdu81

    @dsdu81

    2 ай бұрын

    Thanks for sharing. I also used the code above when seeing the error shown on my airflow web page.

  • @7alexopoulos
    @7alexopoulos10 ай бұрын

    Congrats Marc, great content!

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thanks a lot!

  • @dsdu81
    @dsdu812 ай бұрын

    Thank you so much for this amazing project. Learn a lot!!

  • @MarcLamberti

    @MarcLamberti

    2 ай бұрын

    You're very welcome!

  • @vjvan9338
    @vjvan93383 ай бұрын

    Great Content! Thanks for offering this

  • @furkanyusufpek
    @furkanyusufpek10 ай бұрын

    very good project, thanks for sharing Marc

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    You’re welcome 🫶

  • @hemkumarchheda1581
    @hemkumarchheda158110 ай бұрын

    Wow such a huge video. I enjoyed every part of it. I would love to see more end to end projects like this using airflow. Thank you so much for all your efforts Marc 🙏

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you so much! More will come then ❤

  • @TheGutxD
    @TheGutxD9 ай бұрын

    Que conteúdo incrível! muito obrigado por compartilhar tanto conhecimento!!! abraços from Brasil

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Thank you so much!

  • @MatN-cl7bc
    @MatN-cl7bc6 ай бұрын

    Hi @MarcLamberti ! Thank you so much for making this video. I have one question so far, in the dbt section to be precise, did you do something else between 30:47 and 30:49? because when running the bash commands I can see that my dbt folder looks much more different than yours, in the later timestamp it appears to be 2 new folders: dbt_packages and logs.

  • @user-ob6zr2px9q
    @user-ob6zr2px9q6 ай бұрын

    Very nice Thank You marc.

  • @baronk3558
    @baronk35585 ай бұрын

    Great content! Would it possible to have some videos about how to configure cosmos with cloud composer on gcp? Much appreciated!

  • @dogucanelci4923
    @dogucanelci49233 ай бұрын

    Thank you so much for the project, i just finished and it was amazin, i have a question, is that possible to deploy the container as VM in google cloud ?

  • @assieneolivier5560
    @assieneolivier55605 ай бұрын

    Just by the accent I assume that you are a french speaker. It would be great if you can make videos in french also. Great and explicative video!

  • @lesa7p2lmansion
    @lesa7p2lmansion8 ай бұрын

    End to end projects are the best to be added in portfolio section in the cv

  • @MarcLamberti

    @MarcLamberti

    8 ай бұрын

    That’s right ☺️

  • @johnnote7
    @johnnote77 ай бұрын

    Very nice Thank you.

  • @MarcLamberti

    @MarcLamberti

    7 ай бұрын

    Thank you!

  • @alvaro.2c
    @alvaro.2c5 ай бұрын

    This is a great project! I have a question though, I used it as a template for a project of my own (using astro and same docker image) and everything seems to work great except I believe I don't have writing rights inside of the container (PermissionError: [Errno 13] Permission denied). I found out when trying to run a function with PythonOperator, but also seems to happen with BashOperator if I wanted to create a directory for example. When inside I tested making a directory or creating a file with bash and permission was also denied. I've tried RUN chmod 777 in the dockerfile without success. I am pretty sure it is something relatively simple but I haven't found any solution online yet. Thanks!

  • @eldardragomir6705
    @eldardragomir670510 ай бұрын

    Hi Marc, following your guide, so far so good, but I haven't finished it yet... Mistyping in Notion guide: 1. Keypath JSON -> Keyfile Path 2. "airflow tasks test retail raw_to_gcs 2023-01-01" -> "airflow tasks test retail upload_csv_to_gcs 2023-01-01"

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you so much! Will make the edits!

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Fixed!

  • @eldardragomir6705

    @eldardragomir6705

    10 ай бұрын

    Update2. 1. "airflow tasks test retail check_extract 2023-01-01" -> "airflow tasks test retail check_load 2023-01-01" 2. "project.yml" -> "dbt_project.yml" 3. "target_name='dev',cos -> "target_name='dev', 4. Reports astro dev bas -> astro dev bash cd /usr/local/airflow -> cd include/dbt 5. report_customer_invoices => report_customer_invoices.yml report_product_invoices => report_product_invoices.yml report_year_invoices => report_year_invoices.yml 6. code section for chain is missing Thank you so much for this video. I work primarily with Databricks, and I wanted to look if somebody is able to create a real pipeline demo guide and what's the situation with other paths of DE like Snowflake+dbt, Airflow+dbt . I see that all cool stuff are actually not free, so people have to pay for comfort: "less pain in ass" Airflow (astronomer) + for DQ soda.io + for dbt + for DWH + dashboard probably... Thanks again!

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    @@eldardragomir6705 Thank you for your feedback! Well, I would say all of that cool stuff is free unless you want it managed by someone else. Otherwise, Airflow, codre dbt, soda and metabase are free :)

  • @ChristopherGarcia-cl9ut
    @ChristopherGarcia-cl9ut6 ай бұрын

    Very interesting video, but I have certain functional doubts about working with a cloud to ingest data. This is regarding the example in the video with the CSV file, and I apologize for my ignorance. What would be the difference in bash processes or real-time processing, knowing that in my organization, the data source is a data warehouse? I understand that I could do the same with DQA and DBT. I don't see the advantage of using BigQuery.

  • @sebastiangiraldo5087
    @sebastiangiraldo50873 ай бұрын

    Hey Marc, such a cool project!!! Thanks a lot. But I am having the weirdest issue, when I go into astro dev bash, and try to run dbt from the command line, all the comments just have 0 output and do nothing. They don't fail, but don't work either, and have a blank output

  • @dogucanelci4923
    @dogucanelci49233 ай бұрын

    I have a question, do you suggest that we deploy and test all process in local container by astro, then upload the image in cloud as compute instance, or totally work with google composer ?

  • @xmagcx1
    @xmagcx110 ай бұрын

    excellent content ❤

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you so much!

  • @Obtemus
    @Obtemus9 ай бұрын

    That's really great tutorial. Very useful. but what are the concerns/steps if we want to put this into CI/CD environment to be pushed to production for example?

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Next video, stay tuned 😃

  • @Obtemus

    @Obtemus

    9 ай бұрын

    @@MarcLamberti that would be too great 😃

  • @adityasvasisht4743

    @adityasvasisht4743

    8 ай бұрын

    @@MarcLamberti Yes! We need this video!!

  • @ektagoyal27march
    @ektagoyal27march4 ай бұрын

    Hi Mark Can you help me understand how do we actually host Airflow in real world? How it is installed by organizations and how access is granted and how Developer uses it?

  • @jsat8378
    @jsat83783 ай бұрын

    great job, I have enjoyed every part of it.. just have a question I am at the part with DbtTaskGroup on airflow.. in the video in the airflow UI, the DAG graph in the dbt task group you have for every transform task a test task as well, but I don't have them.. why is that? same thing about the report tasks on UI

  • @dsdu81

    @dsdu81

    2 ай бұрын

    not sure it could help or not. I faced the same problem. but it worked after closing the web page and reconnecting to the local host

  • @blitttzzz
    @blitttzzz10 ай бұрын

    thanks a lot for a very detailed demo. Your course on Udemy also rocks!!

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you so much 🫶

  • @TheBudin1993
    @TheBudin19934 ай бұрын

    hey Marc, thanks for the amazing project! i have one quick doubt: around 27 to 28:00 minute mark, is it necessary to make the includes inside the function? like below the definition for example: 28:36 -> "from soda.scan import Scan" ? or it is the same to import in the header of a python file like we are used to do? thank you in advance

  • @MarcLamberti

    @MarcLamberti

    3 ай бұрын

    It’s necessary as the python code here runs in a python virtual environment

  • @hosseineivazy3261
    @hosseineivazy32619 ай бұрын

    so helpful

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Thank you 🙏

  • @RoseLK
    @RoseLK4 ай бұрын

    Hi @Marc, when I run "astro dev start", it doesn't return any log or pass/fail anything, totally blank. I was looking for solution but couldn't find out. Can you help?

  • @totnguyen3308
    @totnguyen33083 ай бұрын

    Hi Marc, thanks for this project. At 44:00 my airflow doesn't show full dbt tasks (no dim_run and dim_test) even though I followed your instructions exactly step by step. Can you help me fix this?

  • @sirinebouksila9631

    @sirinebouksila9631

    Ай бұрын

    Same here

  • @alanix89

    @alanix89

    21 күн бұрын

    @@sirinebouksila9631 same here, do you faind any solution?

  • @avinashmaddala7717
    @avinashmaddala771710 ай бұрын

    nice video. Can please make a video on airflow managed instance in azure

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Could be a great idea :)

  • @Gregorysharkov
    @Gregorysharkov10 ай бұрын

    Nice video. You can also take a look at kedro framework

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you 🫶

  • @agustincaldart2630
    @agustincaldart26307 ай бұрын

    Hello Marc nice work! i has a problem with dbt command line, when a try dbt deps in "/usr/local/airflow/include/dbt" does nothing but when i create new directory .dbt in "/usr/local/airflow/ " and move .yml in new directory it works, do you have any idea why it might be?

  • @MarcLamberti

    @MarcLamberti

    7 ай бұрын

    hm, I need to try again, maybe something has changed or I made a mistate. What's the timecode where I show that?

  • @agustincaldart2630

    @agustincaldart2630

    7 ай бұрын

    Thanks for answering. It doesn't do anything, I could still fix it with sudo chmod 777 -R retail_airflow i think dbt deps dont log error for problem with permissions @@MarcLamberti

  • @hamzad1128

    @hamzad1128

    7 ай бұрын

    I have a similar issue, dbt deps & dbt run --profiles-dir /usr/local/airflow/include/dbt/ don't do anything.

  • @VNaesthetic_coder
    @VNaesthetic_coder3 ай бұрын

    I missunderstand at 26:49, why we need create that vm ???

  • @Mehtre108
    @Mehtre1084 ай бұрын

    Any aws data engineer project which will be explained in interview sir

  • @azizbohra6487
    @azizbohra64874 ай бұрын

    The only manual thing which is the Querying of the country Table in Bigquery can be added as a function in DAG chain. If anyone interested mention me in the comment, I can help you out. And THANKS Marc!

  • @yudistiraaditya2249
    @yudistiraaditya22497 ай бұрын

    Hello marc! thank youu for your great explanation. But I want to ask why I cant import cosmos although in that env astronomer-cosmos already installed? it's already 2 days and I still cant figure it out lol this project stuck after building the models in BQ (for me) :(

  • @MarcLamberti

    @MarcLamberti

    7 ай бұрын

    What do you mean by you can’t import it?

  • @yudistiraaditya2249

    @yudistiraaditya2249

    7 ай бұрын

    @@MarcLamberti I dont know sir, so what I did is installing it manually using pip instead of using requirement.txt (?) but now I experience a new issue: in DBT_CONFIG = ProfileConfig(profiles_yml_filepath) always return as None although the path is correct. Maybe my dags error because of this one issue. Any help sir?

  • @brunocampos5010
    @brunocampos50102 ай бұрын

    Hi Marc and guys, how can I increase the time out of airflow in this project?

  • @MarcLamberti

    @MarcLamberti

    Ай бұрын

    What do you mean by the time out of airflow?

  • @user-gc4ex5er2g
    @user-gc4ex5er2g3 ай бұрын

    Any reason why you create the dot folder under include. Most tutorials I seen it is included under dags folder.

  • @MarcLamberti

    @MarcLamberti

    3 ай бұрын

    What’s not DAG should not be in the DAGs folder :)

  • @jaimeandressalasmoreira8880
    @jaimeandressalasmoreira88806 ай бұрын

    Hi Marc I want to trigger the completed dag but give me error in the transform, what is the trouble ?

  • @MarcLamberti

    @MarcLamberti

    6 ай бұрын

    What error?

  • @Shrew_Bucket
    @Shrew_Bucket5 ай бұрын

    Hi I have troubles, after running "dbt deps" command nothing happens what should i do ?

  • @xandao30

    @xandao30

    2 ай бұрын

    I have the same problem

  • @hassanabbasi4164
    @hassanabbasi416410 ай бұрын

    nice tutorial, just a quick question: why (paid)Soda and why not (FREE) Great Expectations ?

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Thank you! Well, Soda is free, but Soda cloud is not. You can use Soda without the cloud offering. Great expectations is *in my opinion* way too hard just for making data quality checks. I found Soda much easier to set up and use.

  • @TheSergioPestana

    @TheSergioPestana

    7 ай бұрын

    @@MarcLamberti Hi Marc. So after the 45 days trial I still can run this project?

  • @SaltineCracker610
    @SaltineCracker610Ай бұрын

    Does anyone only have 4 jobs instead of 8 within the dbtTaskgroup task in airflow? I only have "*_run" jobs but not "*_test" jobs. Any help is appreciated. Thanks!

  • @xxkall08xx

    @xxkall08xx

    Ай бұрын

    Same here, I believe he did not show that.

  • @dan_dom
    @dan_dom9 ай бұрын

    There is a problem somewhere in the dependencies, because I cant seem to install protobuf==3.20 and cosmos with 1.0.3 at the same time, not sure how you were able to do that.

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    what's your astro-runtime version in the dockerfile?

  • @dan_dom

    @dan_dom

    9 ай бұрын

    @@MarcLamberti 9.1.0, but I can try 8.8 as you have in the video and see if that fixes it, its true that is a jump between major versions.

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    @@dan_dom Yes, could you try? In the meantime I'm checking how to solve that

  • @nihildev6105
    @nihildev61059 ай бұрын

    Getting Error: The conflict is caused by: 8.521 soda-core 3.0.45 depends on opentelemetry-api~=1.16.0 8.521 apache-airflow 2.7.0+astro.1 depends on opentelemetry-api==1.15.0 8.521 8.521 To fix this you could try to: 8.521 1. loosen the range of package versions you've specified 8.521 2. remove package versions to allow pip attempt to solve the dependency conflict I get it when inserting soda in the requirements.txt

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Let me check

  • @tourist2384
    @tourist23848 ай бұрын

    at 40:50, how you can folder dbt_packages and logs :///

  • @MarcLamberti

    @MarcLamberti

    8 ай бұрын

    what do you mean?

  • @redouanelamkadem6804
    @redouanelamkadem68049 ай бұрын

    I am getting an error while launching airflow tasks test retail gcs_to_raw 2023-01-01 : UnicodeDecodeError: 'utf-8' codec can't decode byte 0xa3 in position 227179: invalid start byte Any ideas ? Thanks !

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Yes, open the file with Notepad or VSCode and make sure to save it with the UTF-8 encoding then reupload the file to GCS and it will work.

  • @user-sc1ur8wp6h
    @user-sc1ur8wp6h9 ай бұрын

    I followed the steps but got an error when including DBT project in airflow. the error was: AttributeError: 'ProfileConfig' object has no attribute 'validate_project'. Did you mean: 'validate_profile'? Could you let me know what could have gone wrong?

  • @user-sc1ur8wp6h

    @user-sc1ur8wp6h

    9 ай бұрын

    This was the complete error message: Broken DAG: [/usr/local/airflow/dags/run_template_best_target.py] Traceback (last most recent call): File "/usr/local/lib/python3.10/site-packages/cosmos/airflow/task_group.py", line 26, in __init__ DbtToAirflowConverter.__init__(self, *args, **specific_kwargs(**kwargs)) File "/usr/local/lib/python3.10/site-packages/cosmos/converter.py", line 106, in __init__ project_config.validate_project() AttributeError: 'ProfileConfig' object has no 'validate_project' attribute. Did you mean: 'validate_profile'?

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Can you double check your profile file?

  • @user-sc1ur8wp6h

    @user-sc1ur8wp6h

    9 ай бұрын

    ​@@MarcLamberti Thanks for replying, Marc​ @MarcLamberti ! I believe that my profiles.yml is correct, because if I run the dbt directly through the terminal in my project, it works. But performing DbtTaskGroup in Airflow gives this error.

  • @brunocampos5010
    @brunocampos50103 ай бұрын

    Hi guys, aftet all project and delete the tables on GCP, I got this error in the first task, when I started the tasks on airflow: airflow.exceptions.AirflowNotFoundException: The conn_id `gcp` isn't defined Please, can someone help me?

  • @brunocampos5010

    @brunocampos5010

    3 ай бұрын

    Log complete: airflow.exceptions.AirflowNotFoundException: The conn_id `gcp` isn't defined [2024-02-23, 00:05:58 UTC] {taskinstance.py:1345} INFO - Marking task as FAILED. dag_id=retail, task_id=upload_csv_to_gcs, execution_date=20240222T015123, start_date=20240223T000558, end_date=20240223T000558 [2024-02-23, 00:05:58 UTC] {standard_task_runner.py:104} ERROR - Failed to execute job 15 for task upload_csv_to_gcs (The conn_id `gcp` isn't defined; 688) [2024-02-23, 00:05:58 UTC] {local_task_job_runner.py:225} INFO - Task exited with return code 1 [2024-02-23, 00:05:58 UTC] {taskinstance.py:2653} INFO - 0 downstream tasks scheduled from follow-on schedule check

  • @MarcLamberti

    @MarcLamberti

    3 ай бұрын

    It looks like you’re using a connection gcp that you haven’t defined yet in the Airflow UI, look at your connections :)

  • @adityadomala
    @adityadomala6 ай бұрын

    Hi im facing problem with metabase, it is not showing up

  • @adityadomala

    @adityadomala

    6 ай бұрын

    @MarcLamberti

  • @adedamolaadesoye

    @adedamolaadesoye

    3 ай бұрын

    hello! i had an issue with Metabase too. it wasn't starting up after running "astro dev restart". it seemed docker wasn't recognizing the "docker-compose-override.yml" file since there was no error. i later realized i misspelled the file's name. it's ".override.yml" not "-override.yml". i hope this helps.

  • @TEACHMECADDESIGN
    @TEACHMECADDESIGN9 ай бұрын

    I am getting erro while installing soda-core-bigquery==3.0.45 using requirements.txt here is the error ERROR: Cannot install apache-airflow==2.7.0+astro.1 and soda-core-bigquery because these package versions have conflicting dependencies. #0 20.50 #0 20.50 The conflict is caused by: #0 20.50 soda-core 3.0.45 depends on opentelemetry-api~=1.16.0 #0 20.50 apache-airflow 2.7.0+astro.1 depends on opentelemetry-api==1.15.0 #0 20.50 #0 20.50 To fix this you could try to: #0 20.50 1. loosen the range of package versions you've specified #0 20.50 2. remove package versions to allow pip attempt to solve the dependency conflict

  • @moozcast7837
    @moozcast78379 ай бұрын

    Hello I am getting encoding error UnicodeDecodeError: 'utf-8' codec can't decode byte 0xa3 in position 227179: invalid start byte while running gcs_to_raw

  • @moozcast7837

    @moozcast7837

    9 ай бұрын

    The way I solved it (I guess there is better way), open the csv with pandas and put encoding latin therefore download new csv and use that for tutorial

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Thank you for sharing. Or you can open the file with VSCode or Notepad and save the file again with utf8 encoding

  • @qazaqempire2446
    @qazaqempire24468 ай бұрын

    i tried to do it with aws managed airflow - and failed. damn.

  • @MarcLamberti

    @MarcLamberti

    8 ай бұрын

    don't use MWAA 🥹

  • @azizbohra6487
    @azizbohra64874 ай бұрын

    Error.... Can someone help me? Airflow is starting up! Error: there might be a problem with your project starting up. The webserver health check timed out after 1m0s but your project will continue trying to start. Run 'astro dev logs --webserver | --scheduler' for details. Try again or use the --wait flag to increase the time out

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    I am guessing you are using astro version 8.8.0 If yes then revert back to what it was before and read my another comment which has the solution

  • @azizbohra6487

    @azizbohra6487

    4 ай бұрын

    Yes, before it was astro-runtime:10.2.0@@sprinter5901

  • @azizbohra6487

    @azizbohra6487

    4 ай бұрын

    Yes. it was astro 10.2.0@@sprinter5901 , i cant find your other comment?

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    ​@@azizbohra6487Hi currently I am not on my pc. Just sort comments with most recent and you will find it

  • @sprinter5901

    @sprinter5901

    4 ай бұрын

    Hi so just like everyone else here I faced similar issueduring dbt part. To solve that in requirements fileuse this code instead of one mentioned in video. astronomer-cosmos[dbt-bigquery] protobuf Dont put any version number ahead. Once changesare done do astro dev restart. It will take some timebut it worked for me.

  • @theniyota
    @theniyota8 ай бұрын

    I am getting this error. Can someone help me? Airflow is starting up! Error: there might be a problem with your project starting up. The webserver health check timed out after 1m0s but your project will continue trying to start. Run 'astro dev logs --webserver | --scheduler' for details. Try again or use the --wait flag to increase the time out

  • @MarcLamberti

    @MarcLamberti

    8 ай бұрын

    Can you looks at the logs as suggested?

  • @theniyota

    @theniyota

    8 ай бұрын

    @@MarcLamberti I did that and it says that it is waiting for port 5432 of postgres. It seems that the port is being used, however I modified the yaml and set the port to 5433 and the problem still there.

  • @theniyota

    @theniyota

    8 ай бұрын

    @@MarcLamberti I managed to solved the issue. It seems the docker desktop app was the issue. I uninstalled and reinstalled the app. Now it is working well. Thanks for your effort

  • @agustincaldart2630

    @agustincaldart2630

    7 ай бұрын

    @@theniyota Ty bro this comment safe my time

  • @ogunniransiji2686

    @ogunniransiji2686

    6 ай бұрын

    @@theniyota Thanks Man

  • @shrikantkoli-eq7hc
    @shrikantkoli-eq7hcАй бұрын

    Very Fast

  • @nguyentrannhat6199
    @nguyentrannhat61996 ай бұрын

    Hi @MarcLamberti ! I have the problem: unable to run this(no error but no tables in bigQuery,any outputs when runing commands):dbt deps dbt run --profiles-dir /usr/local/airflow/include/dbt/

  • @Shrew_Bucket

    @Shrew_Bucket

    5 ай бұрын

    same, did you found the solution ?

  • @cesar222vinicius

    @cesar222vinicius

    4 ай бұрын

    Same here! Somehow after dbt deps or even dbt run --profiles-dir /path got nothing from terminal and nothing on big query. Tried to include --print or --no-quiet but got anything as well. Did you found the solution? ps: I'm using linux (ubuntu 22.04LTS)

  • @Shrew_Bucket

    @Shrew_Bucket

    4 ай бұрын

    @@cesar222vinicius nah man, the only way is to setup airflow by your self without astra cli, or just try to find same project as astra. Personalny I recommend first way. And do not start from scratch but with airflow docker image available in airflow docs

  • @chayanshrangraj4718
    @chayanshrangraj47189 ай бұрын

    Hi, Thanks for this amazing tutorial. I really appreciate the effort and time that you put in it. But when I install soda-core bigquery, there is a dependency issue which I can't seem to resolve and need your help, I hope you can help because I really want to complete this project. Versions trying to install: apache-airflow-providers-google==10.3.0 soda-core-bigquery==3.0.45 Error: ERROR: Cannot install -r requirements.txt (line 6) because these package versions have conflicting dependencies. #9 34.65 #9 34.65 The conflict is caused by: #9 34.65 soda-core-bigquery 3.0.41 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.40 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.39 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.38 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.37 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.35 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.34 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.33 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.32 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.31 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.30 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.29 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.28 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.27 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.26 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.25 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.24 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.23 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.22 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.21 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.20 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.19 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.18 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.17 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.16 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.15 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.14 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.13 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.12 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.11 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.10 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.9 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.8 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.7 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.6 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.5 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.4 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.3 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.2 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.1 depends on google-cloud-bigquery=2.25.0 #9 34.65 soda-core-bigquery 3.0.0 depends on google-cloud-bigquery=2.25.0 #9 34.65 #9 34.65 To fix this you could try to: #9 34.65 1. loosen the range of package versions you've specified #9 34.65 2. remove package versions to allow pip attempt to solve the dependency conflict #9 34.65 #9 34.65 ERROR: ResolutionImpossible: for help visit pip.pypa.io/en/latest/topics/dependency-resolution/#dealing-with-dependency-conflicts

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    let me double check

  • @chayanshrangraj4718

    @chayanshrangraj4718

    9 ай бұрын

    @@MarcLamberti Thank you! It would nice also if you could pin the solution because I think others also might be facing the same issue.

  • @guesmiabderraouf6133
    @guesmiabderraouf613310 ай бұрын

    unable to run this(no error but no tables in bigQuery,any outputs when runing commands):dbt deps dbt run --profiles-dir /usr/local/airflow/include/dbt/

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    make sure that you are in the include/dbt folder before executing dbt deps and dbt run

  • @guesmiabderraouf6133

    @guesmiabderraouf6133

    10 ай бұрын

    @@MarcLamberti ​ @MarcLamberti ,yes I'am in the correct folder: (dbt_venv)astro@a1629bd2ef32:/usr/local/airflow/include/dbt$ dbt deps (dbt_venv) astro@a1629bd2ef32:/usr/local/airflow/include/dbt$ dbt run --profiles-dir /usr/local/airflow/include/dbt/ (dbt_venv) astro@a1629bd2ef32:/usr/local/airflow/include/dbt$

  • @Facu55

    @Facu55

    10 ай бұрын

    I'm encountering the same issue. It seems like dbt is not installed or something because it doesn't even throw an error.

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    @@Facu55 can you connect with me on LinkedIn and send me a screenshot of your error?

  • @Facu55

    @Facu55

    9 ай бұрын

    @@MarcLamberti Done!

  • @user-kq3br9tb8i
    @user-kq3br9tb8i9 ай бұрын

    I get the following error when testing either the create dataset task or the gcs_to_raw task: "OSError: Could not find lib geos_c or load any of its variants ['libgeos_c.so.1', 'libgeos_c.so']."

  • @MarcLamberti

    @MarcLamberti

    9 ай бұрын

    Keep the same versions as shown in the pinned comment and the video. I have the same error with the latest versions

  • @user-kq3br9tb8i

    @user-kq3br9tb8i

    9 ай бұрын

    @@MarcLamberti Thanks, managed to complete the pipeline :)

  • @zuandrecoetzee1957
    @zuandrecoetzee195710 ай бұрын

    THANKS ALLOT

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    Happy that it helps :)

  • @zuandrecoetzee1957

    @zuandrecoetzee1957

    10 ай бұрын

    @@MarcLamberti I'm stucked after creating the dbtTaskGroup ---> ValueError: 'source' is not a valid DbtResourceType

  • @zuandrecoetzee1957

    @zuandrecoetzee1957

    10 ай бұрын

    @MarcLamberti can you help me, with the issue been stuck here for 3 days?

  • @MarcLamberti

    @MarcLamberti

    10 ай бұрын

    @@zuandrecoetzee1957 what issue?

  • @zuandrecoetzee1957

    @zuandrecoetzee1957

    10 ай бұрын

    @@MarcLamberti Dag Import error: ValueError: 'source' is not a valid DbtResourceType. I tested the transformation model and it completed successfully. I was able to confirm the dataset exist on big query .....when I add the task(dbt task group) then my dag breaks.

  • @moozcast7837
    @moozcast78379 ай бұрын

    I am really trying to follow all the steps but every time I encounter error. Now this ERROR: failed to solve: process "/bin/bash -o pipefail -e -u -x -c if grep -Eqx 'apache-airflow\\s*[=~>]{1,2}.*' requirements.txt; then echo >&2 \"Do not upgrade by specifying 'apache-airflow' in your requirements.txt, change the base image instead!\"; exit 1; fi; pip install --no-cache-dir --root-user-action=ignore -r requirements.txt" did not complete successfully: exit code: 1 Error: command 'docker build -t pipeline-tutorial_04e6a1/airflow:latest failed: failed to execute cmd: exit status 1

  • @huynguyentan4532

    @huynguyentan4532

    8 ай бұрын

    Hi, I faced the same and then I install "Microsoft Visual C++" then it worked. Hope it can help.

Келесі