Airflow XCom for Beginners - All you have to know in 10 mins

  Рет қаралды 46,673

Data with Marc

Data with Marc

Күн бұрын

Пікірлер: 52
@JavierBeneitoBarquero
@JavierBeneitoBarquero 3 жыл бұрын
Quick and clear. With your Udemy courses and your KZbin videos, I'm learning a lot about Apache Airflow. From Zero to hero in a few weeks. Thx.
@quanminfeng8375
@quanminfeng8375 Жыл бұрын
Best xcom video I watched
@MarcLamberti
@MarcLamberti Жыл бұрын
Thank you 🙏
@waodezalmawati460
@waodezalmawati460 2 жыл бұрын
Whats a clearly explanation! Thankyou so much! Love from Indonesia!❤‍🔥
@guolunli1908
@guolunli1908 2 жыл бұрын
Thank you so much! By following your videos closely I not only avoided bugs but also learned in detail how to set up an airflow pipeline!
@ХеллБой-я1щ
@ХеллБой-я1щ Жыл бұрын
thank you! as it gets very often, some detail is missed by me in order to use new functionality and that detail was ti thanks for explaining!
@pyrojoke2
@pyrojoke2 3 жыл бұрын
Thank you! I spent a few hours trying to figure out how it works, but your tutorial did it in 10 minutes
@anatolys9203
@anatolys9203 Жыл бұрын
great tutorial and explanantion! thank you!
@luuquanghuy8193
@luuquanghuy8193 2 жыл бұрын
Thank u for your sharing, keep it up because u doing that right clearly and easy to understand. Love from Viet Nam
@victortelles9670
@victortelles9670 2 жыл бұрын
Amazing tutorial as always. Love yout channel.
@guyfridman4426
@guyfridman4426 3 жыл бұрын
Thank you marc, I did the course in udemy and it's very recommended
@MarcLamberti
@MarcLamberti 3 жыл бұрын
Thank you!
@shantanubugadi3188
@shantanubugadi3188 2 жыл бұрын
Very well explained...! Very awesome...! I am just enjoying the series
@sodiqafolayan4921
@sodiqafolayan4921 3 жыл бұрын
Thanks Marc as always
@MarcLamberti
@MarcLamberti 3 жыл бұрын
My pleasure!
@АндрейРезниченко-п9ъ
@АндрейРезниченко-п9ъ 2 жыл бұрын
Hi all! Please suggest how to implement the following scenario: Have a dag with sshoperator that executes shell script. Shell script returns different return codes. How to analyze which return code is received??
@dmdv-h1t
@dmdv-h1t 3 жыл бұрын
thank you for clear explanation
@yunusemrahulucay4953
@yunusemrahulucay4953 2 жыл бұрын
Thank you so much. It was really quick and clear.
@kyuukev
@kyuukev Жыл бұрын
Nice video but is there a way to do it between 2 DockerOperator? And if not with the DockerOperator creating some kind of CustomDockerOperator to make it able to do it?
@GustavoCosta-jr1mh
@GustavoCosta-jr1mh 2 жыл бұрын
Thanks for all your videos, Marc. Brilliant content, very straightfoward!
@saritkumarsi4166
@saritkumarsi4166 3 жыл бұрын
Thanks Marc. Great info for a beginner like me :)
@MarcLamberti
@MarcLamberti 3 жыл бұрын
Great pleasure, let me know what you would like to see next :)
@saritkumarsi4166
@saritkumarsi4166 3 жыл бұрын
@@MarcLamberti It would be awesome if you can share some knowledge by taking this tutorial further by adding (if possible) a new service and assigning it a task via DAGs within the Airflow container. Just to give you some background on what I am currently trying to do --> Similar to your compose file, I have Postgres, Airflow Webserver and scheduler services defined in docker compose file and running perfectly. However, I have an extra service (say an Ubuntu server) defined in the same compose file which basically takes an .sh command and runs it. I am trying to send an sh command via DAG DockerOperator, to this 4th container. I took help from your video on DockerOperator as well :). If I understood correctly, the Airflow DAG in that video is running on the host instead from within a docker container. I searched for help on the internet, but haven't come across any. Do let me know if such use case is possible with airflow. Appreciate you help :)
@padegalsaigiriraj3459
@padegalsaigiriraj3459 3 жыл бұрын
Thanks, Marc. Great info Can You Please Confirm This I have Two Tasks in DAG1 Task1 - Normal Function Which does some process Task2 - TriggerDagRunOperator (Trigger DAG2) Can I Use the return value/XCom of task1 in Task2 and use this value in DAG2? Thanks
@Jmignet
@Jmignet 3 жыл бұрын
Pretty enlightening! Thank you very much!
@Jamdat33
@Jamdat33 2 жыл бұрын
Excellent thank you
@bigkongenergy6054
@bigkongenergy6054 3 жыл бұрын
Commander, the aliens continue to make progress on the Avatar Project. If we're going to slow them, we need to move fast.
@marcuscheng9413
@marcuscheng9413 3 жыл бұрын
ok. we're raiding the blacksite.
@prashantjoshi4691
@prashantjoshi4691 3 жыл бұрын
add provide_context = True in task which uses ti in older version of airflow
@thati2792
@thati2792 2 жыл бұрын
can we pass xcom as params in redshiftsqloperator?
@kipodiha
@kipodiha 3 жыл бұрын
Very useful video! after reading airflow documentation and example for me this XCOM was still not clear :( Now I m ok! Thanks a lot!!!
@drakdragon
@drakdragon 3 жыл бұрын
Sir, I tried to do the needful to do good and nice Airflow in the XCom, but my hit chance was still saying 99% chance of to becoming the hit sir, but it still missed most of the time. Sir I do believe you should do the needful by improving the Airflow by using the Minecraft Mushroom Soup Windtunnel.
@ramjan135
@ramjan135 2 жыл бұрын
Hi Marc, how to cross communication data (data sharing) between master_dag and child_dag(this is triggered by master dag)?
@BULLSHXTYT
@BULLSHXTYT 2 жыл бұрын
How to access xcom in subdag from parent dag?
@djalan84
@djalan84 6 ай бұрын
what about sharing data between dags?
@MarcLamberti
@MarcLamberti 6 ай бұрын
You can. Just specify the dag_id in the xcom_pull method.
@wll9085
@wll9085 2 жыл бұрын
useful!
@antoniosaldivar4163
@antoniosaldivar4163 2 жыл бұрын
I have the same xcom key from same task and it does not get replace or overwrite, instead it creates other xcom record with same key and task id
@MarcLamberti
@MarcLamberti 2 жыл бұрын
look at the execution date which should not be the same. That's why you see that. XCOMs are created based on their DAGRun too
@antoniosaldivar4163
@antoniosaldivar4163 2 жыл бұрын
@@MarcLamberti thank you for the info!!, you are right the execution dates (YYYY-mm-dd, HH:mm:ss) are different, I see it has to be executed at the same time to overwrite that XCOM.
@RaviPrakash-vu6hf
@RaviPrakash-vu6hf Жыл бұрын
Hi @@MarcLamberti I have the same issue. I do want to overwrite the value from the last run. I have a DAG that will run every 15 mins and it will push a key to XCOM. Since this key will be stored in the DB, the number of records will keep on growing. Hence, I want to overwrite the value of the key from the previous DAG run. please let me know if that is possible. Thanks!!
@yerkhankabyl6284
@yerkhankabyl6284 2 жыл бұрын
Does someone have the same issue like me? I got 3 “None” -> [None, None, None]
@yerkhankabyl6284
@yerkhankabyl6284 2 жыл бұрын
Oops, I solved this problem, the main error was the name of “Xcom” 😅 Thank u, man, u are awesome (:
@BM-uf4pp
@BM-uf4pp 3 жыл бұрын
The three people who disliked this video are nifi fans
@marcuscheng9413
@marcuscheng9413 3 жыл бұрын
or ADVENT troopers.
@g3rzin
@g3rzin Жыл бұрын
Please don't read the underscore!!!! Just read it a "choose model" and not "choose underscore model"
@MarcLamberti
@MarcLamberti Жыл бұрын
Okkkkkkkkkk!!!!!!!! Will do
@g3rzin
@g3rzin Жыл бұрын
@@MarcLamberti ahahah great! And thanks for teaching me airflow!
The Airflow BranchPythonOperator for Beginners in 10 mins
12:27
Data with Marc
Рет қаралды 20 М.
Airflow DAG: Coding your first DAG for Beginners
20:31
Data with Marc
Рет қаралды 233 М.
Long Nails 💅🏻 #shorts
00:50
Mr DegrEE
Рет қаралды 17 МЛН
А я думаю что за звук такой знакомый? 😂😂😂
00:15
Денис Кукояка
Рет қаралды 4,9 МЛН
The Ultimate Sausage Prank! Watch Their Reactions 😂🌭 #Unexpected
00:17
La La Life Shorts
Рет қаралды 9 МЛН
Don't Use Apache Airflow
16:21
Bryan Cafferky
Рет қаралды 98 М.
Big data in Airflow? Discover the XCom Backends with AWS S3!
20:44
Data with Marc
Рет қаралды 9 М.
Airflow Sensors : Get started in 10 mins
11:55
Data with Marc
Рет қаралды 28 М.
Running Airflow 2.0 with Docker in 5 mins
11:55
Data with Marc
Рет қаралды 173 М.
Airflow Helm Chart : Quick Start For Beginners in 10mins
13:06
Data with Marc
Рет қаралды 21 М.
What's new in Apache Airflow 2.7?
12:55
Data with Marc
Рет қаралды 4,7 М.
Airflow DockerOperator: The Basics (and more 🤫)
19:36
Data with Marc
Рет қаралды 17 М.