我試圖使用spark sql對hive表執行查詢。
下面的代碼可以正常作業
spark=SparkSession.builder.master("local[1]".enableHiveSupport().appName("test").getorCreate()
df=spark.sql("select * from table_name where date='2021-05-16' and name='xxxx'" )
但是我想把日期和名字作為一個變數傳遞，而不是硬編碼到SQL中。
有沒有一種方法可以傳遞date=current_date而不是硬編碼的值
我試圖使用time.strftime將當前日期作為日期傳給查詢，而名字我必須從另一個變數中傳給它 name='XXXX'uj5u.com熱心網友回復：
你能從py檔案的外部傳遞變數嗎？
如果是這樣，你可以試試這個
span class="hljs-keyword">import sys
day = sys.argv[1]
df=spark.sql("select * from table_name where date='%s'"/span> % day)
spark-submit --master yarn test.py 2021-09-17
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/328340.html
標籤：