po prostu uruchomić bardzo proste zadanie następującoAWS Klej zajmuje dużo czasu, aby zakończyć
glueContext = GlueContext(SparkContext.getOrCreate())
l_table = glueContext.create_dynamic_frame.from_catalog(
database="gluecatalog",
table_name="fctable")
l_table = l_table.drop_fields(['seq','partition_0','partition_1','partition_2','partition_3']).rename_field('tbl_code','table_code')
print "Count: ", l_table.count()
l_table.printSchema()
l_table.select_fields(['trans_time']).toDF().distinct().show()
dfc = l_table.relationalize("table_root", "s3://my-bucket/temp/")
print "Before keys() call "
dfc.keys()
print "After keys() call "
l_table.select_fields('table').printSchema()
dfc.select('table_root_table').toDF().where("id = 1 or id = 2").orderBy(['id','index']).show()
dfc.select('table_root').toDF().where("table = 1 or table = 2").show()
Struktura danych jest prosta zbyt
root
|-- table: array
| |-- element: struct
| | |-- trans_time: string
| | |-- seq: null
| | |-- operation: string
| | |-- order_date: string
| | |-- order_code: string
| | |-- tbl_code: string
| | |-- ship_plant_code: string
|-- partition_0
|-- partition_1
|-- partition_2
|-- partition_3
Kiedy uruchomić testu pracy, zajęło wszędzie od Od 12 do 16 minut do końca. Ale dziennik kontroli w chmurze pokazał, że zadanie zajęło 2 sekundy, aby wyświetlić wszystkie moje dane.
Moje pytania brzmią: Gdzie praca AWS Glue może spędzać czas poza rejestracją i co robi poza okresem logowania?