Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/FDA/openfda
/ functions
Functions
1,029 in github.com/FDA/openfda
⨍
Functions
1,029
◇
Types & classes
287
↳
Endpoints
1
↓ 418 callers
Method
get
(self, key)
openfda/parallel/sharded_db.py:45
↓ 393 callers
Function
eq_
Shorthand for 'assert a == b, "%r != %r" % (a, b)
openfda/tests/api_test_helpers.py:121
↓ 53 callers
Method
add
(self, key, value)
openfda/parallel/mapreduce.py:117
↓ 48 callers
Function
ok_
Shorthand for assert. Saves 3 whole characters!
openfda/tests/api_test_helpers.py:114
↓ 34 callers
Method
from_glob
(glob, mr_input=FilenameInput())
openfda/parallel/mapreduce.py:90
↓ 28 callers
Method
put
(self, key, value)
openfda/parallel/sharded_db.py:42
↓ 26 callers
Method
open
Open an existing ShardedDB.
openfda/parallel/sharded_db.py:34
↓ 23 callers
Method
from_sharded
(prefix, mr_input=LevelDBInput())
openfda/parallel/mapreduce.py:94
↓ 22 callers
Function
_add_field
(openfda, field, value)
openfda/spl/annotate.py:33
↓ 22 callers
Function
_add_field
(openfda, field, value)
openfda/res/annotate.py:47
↓ 19 callers
Function
_add_field
(openfda, field, value)
openfda/drugsfda/annotate.py:26
↓ 19 callers
Function
_add_field
(openfda, field, value)
openfda/faers/annotate.py:45
↓ 19 callers
Function
_add_field
(openfda, field, value)
openfda/adae/annotate.py:51
↓ 19 callers
Method
isdigit
(self, s)
openfda/adae/pipeline.py:569
↓ 15 callers
Method
field_val_str
(self, soup, field_key)
openfda/device_recall/pipeline.py:223
↓ 14 callers
Method
map
(self, spl_set_id, value, output)
openfda/spl/pipeline.py:245
↓ 12 callers
Method
range_iter
(self, start_key, end_key)
openfda/parallel/sharded_db.py:48
↓ 12 callers
Method
run
(self)
openfda/drugsfda/pipeline.py:465
↓ 11 callers
Function
_add_field
(openfda, field, value)
openfda/ndc/annotate.py:33
↓ 11 callers
Method
run
(self)
openfda/annotation_table/pipeline.py:365
↓ 10 callers
Method
add
(id, json)
openfda/adae/tests/pipeline_test.py:59
↓ 10 callers
Function
open_data_file
(fname)
openfda/test_common.py:15
↓ 9 callers
Method
as_dict
Returns the content of this database as an in-memory Python dictionary
openfda/parallel/sharded_db.py:59
↓ 7 callers
Function
_joinable_dict
(record_list, join_key_list)
openfda/annotation_table/combine_harmonization.py:34
↓ 7 callers
Function
data_filename
(fname, caller_frame=1)
openfda/test_common.py:8
↓ 7 callers
Function
first_file_timestamp
:param path: path to an existing directory :return: timestamp of the first file found in the given directory as YYYY-MM-DD - If the fi
openfda/common.py:312
↓ 7 callers
Method
from_sharded_list
(shard_list, mr_input=LevelDBInput())
openfda/parallel/mapreduce.py:98
↓ 7 callers
Function
newest_file_timestamp
:param path: path to an existing directory :return: timestamp of the newest file found in the given directory as YYYY-MM-DD
openfda/common.py:337
↓ 7 callers
Method
output
(self)
openfda/common.py:117
↓ 6 callers
Method
__init__
(self, filename, mr_input, start_pos, end_pos)
openfda/parallel/inputs.py:29
↓ 6 callers
Function
first_match_or_empty_string
(matches)
openfda/spl/extract.py:35
↓ 6 callers
Method
run_mr
(self, prefix, input_data, input_format=parallel.LineInput(), mapper=pa
openfda/tests/parallel_test.py:35
↓ 6 callers
Method
verify_parsing
(self, f, actual, msg)
openfda/spl/tests/process_barcodes_test.py:17
↓ 5 callers
Function
build_products_key
(app_number, json)
openfda/drugsfda/pipeline.py:211
↓ 5 callers
Function
build_submissions_key
(app_number, json)
openfda/drugsfda/pipeline.py:333
↓ 5 callers
Method
filter
(self, data, lookup=None)
openfda/maude/pipeline.py:724
↓ 5 callers
Method
process_xpath_map
(self, xpath_map, root_node, json)
openfda/adae/pipeline.py:527
↓ 5 callers
Method
run
(self)
openfda/tests/luigi_test.py:21
↓ 4 callers
Function
__len_check
(chk, _type='EAN13')
openfda/res/ean.py:32
↓ 4 callers
Function
_checked_subprocess
(quiet=False, *args, **kw)
openfda/common.py:121
↓ 4 callers
Function
_combine_dicts
(record_dict, new_data_dict, new_data_key)
openfda/annotation_table/combine_harmonization.py:49
↓ 4 callers
Function
completely_flatten
A Flattening function that takes a highly nested dictionary and flattens it into a single depth dictionary with breadcrumb style keys, {a.b.c:
scripts/generate_fields_yaml.py:47
↓ 4 callers
Function
construct_join_key
A helper function to construct a join key from dictionary values.
openfda/registration/pipeline.py:111
↓ 4 callers
Function
fetch
(query)
openfda/tests/api_test_helpers.py:74
↓ 4 callers
Method
flatten
Helper function which flattens a filtered harmonized db entry. Moves any key/values from the `classification` dictionary to the top-
openfda/device_harmonization/pipeline.py:169
↓ 4 callers
Method
from_list
(list, mr_input=FilenameInput())
openfda/parallel/mapreduce.py:86
↓ 4 callers
Function
normalize_product_name
Simple drugname normalization: strip punctuation and whitespace and lowercase.
openfda/faers/annotate.py:11
↓ 4 callers
Method
output
(self)
openfda/faers/pipeline.py:81
↓ 4 callers
Method
output
(self)
openfda/covid19serology/pipeline.py:63
↓ 4 callers
Function
p
(obj)
openfda/tests/index_util_test.py:16
↓ 4 callers
Function
print_total
(name, query, count=None)
scripts/generate_tests.py:27
↓ 4 callers
Function
read_json_file
(json_file)
openfda/annotation_table/combine_harmonization.py:30
↓ 4 callers
Function
upca_check_digit
(chk)
openfda/res/ean.py:80
↓ 3 callers
Method
__init__
(self, doc_lookup)
openfda/drugsfda/pipeline.py:249
↓ 3 callers
Method
_output_file
(self)
openfda/parallel/watchdog.py:17
↓ 3 callers
Function
_prefix
Helper function that removes the last entry from a '.' delimited string.
scripts/generate_fields_yaml.py:116
↓ 3 callers
Function
assertCorsHeaders
(res)
api/faers/test/integration/cors_test.js:47
↓ 3 callers
Function
batch_dir
(batch)
openfda/device_recall/pipeline.py:51
↓ 3 callers
Method
create
Create a new ShardedDB with the given number of output shards.
openfda/parallel/sharded_db.py:29
↓ 3 callers
Function
ean_check_digit
Returns the checksum digit of an EAN-13/8 code
openfda/res/ean.py:40
↓ 3 callers
Function
fail
(msg)
openfda/tests/api_test_helpers.py:141
↓ 3 callers
Function
fetch_headers
(query)
openfda/tests/api_test_helpers.py:80
↓ 3 callers
Method
field_val_date
(self, soup, field_key)
openfda/device_recall/pipeline.py:239
↓ 3 callers
Function
first_match_or_empty_string
(matches)
openfda/annotation_table/extract_unii.py:48
↓ 3 callers
Function
fixDate
(y, m, d)
openfda/spl/fix_date.py:12
↓ 3 callers
Method
fix_utf8_issues
(self, filename)
openfda/ndc/pipeline.py:74
↓ 3 callers
Method
flag_file
(self)
openfda/spl/pipeline.py:130
↓ 3 callers
Method
flag_file
(self)
openfda/spl/pipeline.py:155
↓ 3 callers
Method
map_shard
(self, map_input, map_output)
openfda/adae/pipeline.py:425
↓ 3 callers
Function
mapreduce
( inputs, mapper, reducer, output_prefix, output_format=LevelDBOutput(), num_shards=None, map_wo
openfda/parallel/mapreduce.py:146
↓ 3 callers
Method
output
(self)
openfda/res/pipeline.py:108
↓ 3 callers
Method
output
(self)
openfda/tobacco_problem/pipeline.py:33
↓ 3 callers
Method
output
(self)
openfda/export/pipeline.py:293
↓ 3 callers
Method
output
(self)
openfda/export/pipeline.py:433
↓ 3 callers
Function
parseNextURL
(link)
api/faers/test/integration/search_after_test.js:166
↓ 3 callers
Function
read_json_file
(json_file)
openfda/res/annotate.py:8
↓ 3 callers
Method
run
(self)
openfda/ndc/pipeline.py:269
↓ 3 callers
Method
run
(self)
openfda/ndc/pipeline.py:315
↓ 3 callers
Function
shell_cmd
(fmt, *args)
openfda/common.py:150
↓ 2 callers
Function
AddHarmonizedRowToOpenfda
(openfda, row)
openfda/res/annotate.py:94
↓ 2 callers
Function
AnnotateDrugByKey
(drug, key, harmonized_dict)
openfda/adae/annotate.py:119
↓ 2 callers
Method
__init__
(self, spl_s3_dir)
openfda/annotation_table/pipeline.py:543
↓ 2 callers
Function
__sum_digits
(chk, start=0, end=1, step=2, mult=1)
openfda/res/ean.py:37
↓ 2 callers
Method
_data
Return a task that supplies the data files to load into ES. By default, this is just `data_source`, but this can be overridden for more
openfda/index_util.py:453
↓ 2 callers
Method
_fetch_ids
(self, start, end)
openfda/device_recall/pipeline.py:206
↓ 2 callers
Function
_formatMessage
Honour the longMessage attribute when generating failure messages. If longMessage is False this means: * Use only an explicit message if it is pro
openfda/tests/api_test_helpers.py:145
↓ 2 callers
Function
_format_cmd
(args, fmt)
openfda/common.py:159
↓ 2 callers
Function
_make_file_name
Helper function for making uniform file names.
openfda/index_util.py:74
↓ 2 callers
Function
_make_partition
Helper function for making the partition object that is appended to manifest.partitions list.
openfda/index_util.py:117
↓ 2 callers
Method
_nonce_file
(self)
openfda/tasks.py:58
↓ 2 callers
Method
_shard_for
(self, key)
openfda/parallel/sharded_db.py:39
↓ 2 callers
Function
_split
Helper function that splits a string into an array, swaps the encoded values for more descriptive ones and then generates an _exact field
openfda/maude/pipeline.py:267
↓ 2 callers
Function
_write_chunk
Helper function for writing out zip file chunks.
openfda/index_util.py:60
↓ 2 callers
Method
add
(self, obj)
openfda/common.py:39
↓ 2 callers
Function
buildURL
(modifiedQueryStr)
api/faers/traversal.js:5
↓ 2 callers
Method
build_date_range_query
(key, start, end, negate=False)
openfda/export/pipeline.py:144
↓ 2 callers
Method
complete
(self)
openfda/tasks.py:77
↓ 2 callers
Function
convert_unicode
(data)
openfda/common.py:300
↓ 2 callers
Method
create_writer
(self, prefix, shard_idx, num_shards)
openfda/parallel/outputs.py:31
↓ 2 callers
Function
extract_counts
(results)
openfda/tests/api_test_helpers.py:16
next →
1–100 of 1,029, ranked by callers