@@ 74-83 (lines=10) @@ | ||
71 | print("Error calling action:", e) |
|
72 | ||
73 | ||
74 | def push_data(args, client, connection_args={}): |
|
75 | print('File Name:', args.file) |
|
76 | my_table = csv.read_csv(args.file) |
|
77 | print('Table rows=', str(len(my_table))) |
|
78 | df = my_table.to_pandas() |
|
79 | print(df.head()) |
|
80 | writer, _ = client.do_put( |
|
81 | pyarrow.flight.FlightDescriptor.for_path(args.file), my_table.schema) |
|
82 | writer.write_table(my_table) |
|
83 | writer.close() |
|
84 | ||
85 | ||
86 | def upload_data(client, data, filename, metadata=None): |
@@ 74-83 (lines=10) @@ | ||
71 | print("Error calling action:", e) |
|
72 | ||
73 | ||
74 | def push_data(args, client, connection_args={}): |
|
75 | print('File Name:', args.file) |
|
76 | my_table = csv.read_csv(args.file) |
|
77 | print('Table rows=', str(len(my_table))) |
|
78 | df = my_table.to_pandas() |
|
79 | print(df.head()) |
|
80 | writer, _ = client.do_put( |
|
81 | pyarrow.flight.FlightDescriptor.for_path(args.file), my_table.schema) |
|
82 | writer.write_table(my_table) |
|
83 | writer.close() |
|
84 | ||
85 | ||
86 | def upload_data(client, data, filename, metadata=None): |