#31 POC for cython with fastavro impl

protocolAggregator/anjunaEnclave/cython_test.py

@@ -0,0 +1 @@
+import fastavro_deserialisation

protocolAggregator/anjunaEnclave/fastavro_deserialisation.pyx

@@ -0,0 +1,16 @@
+import avro.schema
+import convertCsvToJson
+import datetime
+from avro.datafile import DataFileReader, DataFileWriter
+from avro.io import DatumReader, DatumWriter
+from fastavro import writer, reader, parse_schema
+
+start = datetime.datetime.now()
+
+# Reading
+with open('dataOutput.avro', 'rb') as fo:
+    for record in reader(fo):
+        print(record)
+
+print(start)
+print(datetime.datetime.now())

protocolAggregator/anjunaEnclave/fastavro_schema.avsc

@@ -0,0 +1,27 @@
+{
+        "type": "record",
+        "name": "AggregateInput",
+        "fields": [
+          {
+            "name": "anzsic06",
+            "type": "string"
+          },
+          {
+            "name": "Area",
+            "type": "string"
+          },
+          {
+            "name": "year",
+            "type": "string"
+          },
+          {
+            "name": "geo_count",
+            "type": "string"
+          },
+          {
+            "name": "ec_count",
+            "type": "string"
+          }
+        ]
+
+}

protocolAggregator/anjunaEnclave/setup.py

@@ -0,0 +1,6 @@
+from setuptools import setup
+from Cython.Build import cythonize
+
+setup(
+    ext_modules = cythonize("temp.pyx")
+)